【发布时间】:2015-01-20 08:29:58
【问题描述】:
我想监控一个队列,以便在它变空时得到通知。为此,我需要找出队列中有多少消息,并且此任务需要在每个间隔前运行。每 15 秒一次。
我很困惑阅读那些说你不应该在工作人员中使用 celerybeat 进行生产的文档,这是否意味着我需要创建一个单独的 python 脚本来利用周期性任务?不知道如何实现。
【问题讨论】:
-
在另一个进程中运行 beat:
$ celery beat
我想监控一个队列,以便在它变空时得到通知。为此,我需要找出队列中有多少消息,并且此任务需要在每个间隔前运行。每 15 秒一次。
我很困惑阅读那些说你不应该在工作人员中使用 celerybeat 进行生产的文档,这是否意味着我需要创建一个单独的 python 脚本来利用周期性任务?不知道如何实现。
【问题讨论】:
$ celery beat
【讨论】:
-B 选项的工作人员在每个时间间隔运行该选项?如果一个worker没有指定-B,它会忽略它吗?
celery beat -A periodic_task 运行工人