我有两个django应用程序使用相同的数据库。既用芹菜,又有自己的CELERYBEAT_SCHEDULE。是否有办法区分哪些任务应该在适当的芹菜工人中执行?现在,这两个应用程序的任务都安排在同一个工作人员中。其原因是(?) CELERYBEAT_SCHEDULER to 'djcelery.schedulers.DatabaseScheduler'。我找不到任何不使用数据库的方法/调度器。作为一个代理,我使用的是redis (每个应用程序都是本地的/不同的),所以来自CELERYBEAT_SCHEDULE之外的任务是正常工作的。
发布于 2015-11-24 13:13:21
您可以在CELERY_QUEUES设置中定义两个队列,并使用--queues=queue1参数将一个队列分配给每个celerybeat。
您可以使用以下选项将任务分配到特定队列:
'options': {'queue': 'queue1'},https://stackoverflow.com/questions/33893648
复制相似问题