一時停止とパージ

キューから接続中のコンシューマーへのメッセージ配信を一時停止できます。コンシューマー Worker が不健全なときなど、ダウンタイムを扱う際に、メッセージを失わずにキューを一時停止できます。

配信を一時停止していても、キューはメッセージの受信と保存を続けます。一時停止中のキュー内のメッセージも、キューのメッセージ保持期間を超えると期限切れになります。

一時停止は、プッシュ型のコンシューマー Worker と プル型コンシューマー の両方に影響します。

次のコマンドで、キューからのメッセージ配信を一時停止します。

$ npx wrangler queues pause-delivery <QUEUE-NAME>

• queue-name string required
  • 配信を一時停止するキューの名前。

次のコマンドで、メッセージ配信を再開します。

$ npx wrangler queues resume-delivery <QUEUE-NAME>

• queue-name string required
  • 配信を再開するキューの名前。

キューが一時停止していると、HTTP プル型コンシューマー はメッセージをプルできません。メッセージのプルリクエストは 409 レスポンスと、queue_delivery_paused というエラーメッセージを受け取ります。

キューをパージすると、現在 Queue に保存されているメッセージは完全に削除されます。新しいアプリケーションの開発中、特にテストデータを消すときに便利です。本番環境でも、不正なメッセージのバッチが Queue に送られた場合の対処に使えます。

コンシューマーが処理中の in-flight メッセージは、処理が続く場合があります。パージ操作中にキューへ送られたメッセージは、パージされないことがあります。遅延メッセージもキューから削除されます。

次のコマンドで、キューのメッセージをパージします。操作を確認するため、キュー名の入力を求められます。

$ npx wrangler queues purge <QUEUE-NAME>

This operation will permanently delete all the messages in Queue <QUEUE-NAME>. Type <QUEUE-NAME> to proceed.

キューのパージは、削除するメッセージ数にかかわらず、課金対象の操作 1 回としてカウントされます。たとえば 100 件のメッセージがあるキューをパージすると、100 件すべてが完全に削除され、課金対象の操作は 1 回です。Queues の課金方法の詳細は、料金 を参照してください。