← Cloudflare Queues / queues / observability

Метрики

Queues предоставляет метрики, которые позволяют оценить бэклог очереди, параллелизм потребителей и операции с сообщениями.

Метрики, отображаемые в Панель управления Cloudflare ↗ запрашиваются из Cloudflare GraphQL Analytics API. Вы можете получить доступ к метрикам программно через GraphQL или HTTP-клиент.

Queues экспортирует приведённые ниже метрики в рамках queuesBacklogAdaptiveGroups набор данных.

queuesBacklogAdaptiveGroups набор данных предоставляет следующие измерения для фильтрации и группировки запросов:

• queueID: идентификатор очереди
• datetime: отметка времени отправки сообщения
• date: отметка времени отправки сообщения, усечённая до начала дня
• datetimeHour: отметка времени отправки сообщения, усечённая до начала часа
• datetimeMinute: отметка времени отправки сообщения, усечённая до начала минуты

Queues экспортирует приведённые ниже метрики в рамках queueConsumerMetricsAdaptiveGroups набор данных.

queueConsumerMetricsAdaptiveGroups набор данных предоставляет следующие измерения для фильтрации и группировки запросов:

• queueID: идентификатор очереди
• datetime: отметка времени для метрик потребителя
• date: отметка времени для метрик потребителя, усечённая до начала дня
• datetimeHour: отметка времени для метрик потребителя, усечённая до начала часа
• datetimeMinute: отметка времени для метрик потребителя, усечённая до начала минуты

Queues экспортирует приведённые ниже метрики в рамках queueMessageOperationsAdaptiveGroups набор данных.

queueMessageOperationsAdaptiveGroups набор данных предоставляет следующие измерения для фильтрации и группировки запросов:

• queueID: идентификатор очереди
• actionType: тип операции с сообщением. Может быть WriteMessage, ReadMessage или DeleteMessage
• consumerType: тип потребителя очереди. Может быть worker или http. Применимо только для ReadMessage и DeleteMessage типы действий
• outcome: результат операции с сообщением. Применимо только для DeleteMessage типы действий. Может быть success, dlq или fail.
• datetime: отметка времени для операции с сообщением
• date: отметка времени для операции с сообщением, усечённая до начала дня
• datetimeHour: отметка времени для операции с сообщением, усечённая до начала часа
• datetimeMinute: отметка времени для операции с сообщением, усечённая до начала минуты

Вы можете получить метрики отставания в реальном времени через REST API для Queues и JavaScript API. Эти метрики показывают значения на определённый момент времени, а не агрегированные данные.

Чтобы получить эти метрики через REST API, используйте конечную точку метрик (/accounts/{account_id}/queues/{queue_id}/metrics).

Эти поля также включены в metadata.metrics при вызове send(), sendBatch(), или metrics() через JavaScript API.

query QueueBacklog(
	$accountTag: string!
	$queueId: string!
	$datetimeStart: Time!
	$datetimeEnd: Time!
) {
	viewer {
		accounts(filter: { accountTag: $accountTag }) {
			queueBacklogAdaptiveGroups(
				limit: 10000
				filter: {
					queueId: $queueId
					datetime_geq: $datetimeStart
					datetime_leq: $datetimeEnd
				}
			) {
				avg {
					messages
					bytes
				}
			}
		}
	}
}

query QueueConcurrencyByHour(
	$accountTag: string!
	$queueId: string!
	$datetimeStart: Time!
	$datetimeEnd: Time!
) {
	viewer {
		accounts(filter: { accountTag: $accountTag }) {
			queueConsumerMetricsAdaptiveGroups(
				limit: 10000
				filter: {
					queueId: $queueId
					datetime_geq: $datetimeStart
					datetime_leq: $datetimeEnd
				}
				orderBy: [datetimeHour_DESC]
			) {
				avg {
					concurrency
				}
				dimensions {
					datetimeHour
				}
			}
		}
	}
}

query QueueMessageOperationsByMinute(
	$accountTag: string!
	$queueId: string!
	$datetimeStart: Date!
	$datetimeEnd: Date!
) {
	viewer {
		accounts(filter: { accountTag: $accountTag }) {
			queueMessageOperationsAdaptiveGroups(
				limit: 10000
				filter: {
					queueId: $queueId
					datetime_geq: $datetimeStart
					datetime_leq: $datetimeEnd
				}
				orderBy: [datetimeMinute_DESC]
			) {
				count
				sum {
					bytes
				}
				dimensions {
					datetimeMinute
				}
			}
		}
	}
}