← Cloudflare Queues / queues / configuration

Приостановка и очистка

Вы можете приостановить доставку сообщений из очереди любым подключенным потребителям. Приостановка очереди полезна при обслуживании простоев (например, если Worker-потребитель работает нестабильно), позволяя не терять сообщения.

Queues продолжают принимать и хранить сообщения, даже когда доставка приостановлена. Сообщения в приостановленной очереди по-прежнему могут истекать по сроку хранения, если превышен период хранения сообщений в очереди.

Приостановка влияет как на push-потребители Workers и потребители с pull-моделью.

Следующая команда приостановит доставку сообщений из вашей очереди:

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

• queue-name string обязательно
  • Имя очереди, для которой требуется приостановить доставку.

Следующая команда возобновит доставку сообщений:

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

• queue-name string обязательно
  • Имя очереди, для которой требуется возобновить доставку.

Когда очередь приостановлена, сообщения не могут быть получены через Потребитель на основе HTTP Pull. Запросы на получение сообщений будут получать 409 , а также сообщение об ошибке следующего содержания: queue_delivery_paused.

Очистка очереди безвозвратно удаляет все сообщения, которые в ней хранятся. Это полезно на этапе разработки нового приложения, например для удаления тестовых данных, а также в продакшене, если в очередь попал пакет некорректных сообщений.

Учтите, что сообщения, которые в момент очистки уже обрабатываются потребителями, могут быть обработаны до конца. Сообщения, отправленные в очередь во время операции очистки, могут не попасть под удаление. Отложенные сообщения при этом также будут удалены из очереди.

Следующая команда очистит сообщения в вашей очереди. Для подтверждения операции потребуется ввести имя очереди.

$ npx wrangler queues purge <QUEUE-NAME>

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

Очистка очереди считается одной тарифицируемой операцией, независимо от количества удаляемых сообщений. Например, если вы очищаете очередь со 100 сообщениями, все 100 сообщений будут удалены безвозвратно, а тарифицирована при этом будет только 1 операция. Подробнее см. в цены для получения дополнительной информации о тарификации Queues.