コンテンツにスキップ

キューの設定

Cloudflare Queuesは、Cloudflareの開発者プラットフォームのコマンドラインインターフェースであるWranglerを使用して設定できます。このプラットフォームには、WorkersR2、およびその他の開発者向け製品が含まれています。

各Workerには、環境変数、トリガー、およびキューなどのリソースを指定するwrangler.toml設定ファイルがあります。Workerとリソース間の通信を有効にするには、Workerプロジェクトのwrangler.tomlファイルにbindingを設定する必要があります。

以下のオプションを使用して、キューを設定します。

プロデューサー

プロデューサーは、1つ以上のキューに書き込むCloudflare Workerです。プロデューサーは、HTTP経由でメッセージを受け入れたり、リクエストを処理する際に非同期でメッセージを書き込んだり、Durable Object内からキューに書き込んだりできます。任意のWorkerがキューに書き込むことができます。

キューに生産するには、wrangler.tomlファイルにbindingを設定します。これらのオプションは、Workerがキューにメッセージを送信したいときに使用されるべきです。

[[queues.producers]]
queue = "my-queue"
binding = "MY_QUEUE"
  • queue 文字列

    • キューの名前。
  • binding 文字列

    • バインディングの名前で、JavaScriptの変数です。

コンシューマー

Workers

1つ以上のキューからメッセージを消費するには、wrangler.tomlファイルにbindingを設定します。これらのオプションは、Workerがキューからメッセージを受信したいときに使用されるべきです。

[[queues.consumers]]
queue = "my-queue"
max_batch_size = 10
max_batch_timeout = 30
max_retries = 10
dead_letter_queue = "my-queue-dlq"

各オプションの最大値を確認するには、Limitsを参照してください。

  • queue 文字列

    • キューの名前。
  • max_batch_size 数値(オプション)

    • 各バッチに許可される最大メッセージ数。
    • デフォルトは10メッセージです。
  • max_batch_timeout 数値(オプション)

    • バッチが満杯になるまで待機する最大秒数。
    • デフォルトは5秒です。
  • max_retries 数値(オプション)

    • メッセージが失敗した場合、またはretryAll()が呼び出された場合の最大リトライ回数。
    • デフォルトは3リトライです。
  • dead_letter_queue 文字列(オプション)

    • メッセージが少なくともmax_retries回処理に失敗した場合に送信する別のキューの名前。
    • dead_letter_queueが定義されていない場合、繰り返し処理に失敗するメッセージは最終的に破棄されます。
    • 指定された名前のキューが存在しない場合、自動的に作成されます。
  • max_concurrency 数値(オプション)

    • 一度に実行できる最大同時コンシューマー数。これを設定しない場合、呼び出しの数は現在サポートされている最大値にスケールします。
    • メッセージがリトライされるときのコンシューマーのオートスケールに関する詳細は、Consumer concurrencyを参照してください。

プルベース

キューには、キューからプルするHTTPベースのコンシューマーを持つことができます。このコンシューマーは、インターネット経由で通信できる任意のHTTPサービスです。プルベースのコンシューマーを設定する方法については、Pull consumersを確認してください。