Сельдерей Почему задача остается в очереди

Поэтому я использую сельдерей с RabbitMQ. У меня есть RESTful API, который регистрирует пользователя. Я использую удаленный работник Сельдерей, чтобы отправить регистрационное письмо асинхронно, чтобы мой API мог быстро реагировать.

from .tasks import send_registration_email def register_user(user_data): # save user to the database etc send_registration_email.delay(user.id) return {'status': 'success'} 

Это прекрасно работает. Электронная почта отправляется в неблокируемом асинхронном режиме (и может быть проведена повторная попытка, если это не помогает). Проблема в том, что я смотрю на консоль управления RabbitMQ. Я вижу, что send_registration_email создал случайную очередь. Что-то вроде:

введите описание изображения здесь

Я вижу, что задача была успешно выполнена. Итак, почему случайная очередь остается на RabbitMQ навсегда? Это полезная нагрузка задачи:

 {"status": "SUCCESS", "traceback": null, "result": true, "task_id": "aad10877-3508-4179-a5fb-99f1bd0b8b2f", "children": []} 

One Solution collect form web for “Сельдерей Почему задача остается в очереди”

Это нормальное поведение, если вы настроили CELERY_RESULT_BACKEND в своих настройках. Пожалуйста, проверьте здесь: описание исходного материала для сельдерея

Вы можете отключить бэкэнд результата или сократить время жизни сообщения.

  • Почему RabbitMQ не сохраняет сообщения в надежной очереди?
  • pika.exceptions.ProbableAuthenticationError при попытке отправить сообщение в удаленную очередь
  • AMQP: подтверждение и предварительная выборка
  • Получение ошибки «pika.exceptions.ConnectionClosed» при использовании rabbitmq в python
  • Должен ли я использовать сельдерей или морковь для проекта Django?
  • Ошибка «неизвестного тега доставки» возникает, когда я пытаюсь отправить сообщения Ack в RabbitMQ с помощью pika (python)
  • Сообщения с очередью RabbitMQ продолжают увеличиваться
  • Как сделать простой Pika SelectConnection для отправки сообщения в python?
  • Состояние задачи сельдерея зависит от CELERY_TASK_RESULT_EXPIRES
  • Книга для Django + Celery + RabbitMQ?
  • Есть ли способ перечислить очереди в кроличнике через pika?
  •  
    Interesting Posts for Van-Lav
    Python - лучший язык программирования в мире.