メトリクス

あなたのアカウントのキューのメトリクスは、Cloudflareダッシュボード ↗を通じて確認できます。Workers > Queues > your Queueに移動し、Metricsタブの下で、最終結果によって処理されたメッセージの数、バックログにあるメッセージの数、その他の重要な指標を示す折れ線グラフを表示できます。

Cloudflareダッシュボードのグラフに表示されるメトリクスは、すべてCloudflareのGraphQL Analytics APIから取得されています。メトリクスにプログラム的にアクセスすることも可能です。

キューのメトリクスは、viewer > accountsの下にある3つの異なるノードに分かれています。GraphQLスキーマをナビゲートし、どのデータが利用可能かを発見する方法については、GraphQLスキーマを探索するを参照してください。

GraphQL Analytics APIについて詳しく知るには、GraphQL Analytics APIを参照してください。

GraphQLクエリを書く

キューのメトリクスを探索する方法の例です。

時間帯ごとの平均キューバックログを取得

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
        }
      }
    }
  }
}