3

我遇到了一个 celery beat 工人没有向 celery 发送任务的问题。Celery 在三台服务器上运行,在 HAProxy 后面有一个 RabbitMQ 集群作为后端。

Celery beat 用于安排每天早上 9 点的任务。当我启动worker时,通常第一个任务成功,但之后似乎以下任务从未发送到rabbitmq。在 celery beat 日志文件中(使用该-l debug选项运行 celery beat),我看到诸如: 之类的消息Scheduler: Sending due task my-task (tasks.myTask),但没有任何 celery worker 正在接收任务的迹象。

我还尝试通过 rabbitmq_tracing 插件在 rabbitmq 中记录消息,这只是确认任务从未到达 rabbitmq。知道会发生什么吗?谢谢!

4

0 回答 0