celery - 如果 celeryd 没有运行，是否可以指定 task.delay 或 task.apply_async 应该失败？

Question

我正在使用 djcelery 和 djkombu。我会使用 RabbitMQ（因为这是推荐的选项），但是 RabbitMQ 在我的 VPS 上使用了太多内存，而且我是个小气鬼。

我认为如果我的代码尝试安排任务并且 celeryd 没有运行，那么在我的应用程序中抛出异常会很好。这是一种由主管、nagios 等监控 celeryd 的备用计划。

起初我以为immediate设置会这样做，但它不适用于我的 Django ORM 配置。

Answer 1

问题主要在于使用此命令向代理发送简单消息，基本上代理只是存储消息并等待使用它的人。这种架构很酷的一点是，如果一个 celery worker 宕机了两次，当它再次运行时，它会开始获取代理中的所有旧计划任务。如果您不希望您的项目出现这种行为，那么 celery 可能是错误的选择。