0

我有两个使用相同数据库的 django 应用程序。既使用芹菜，又拥有自己的CELERYBEAT_SCHEDULE。有没有办法区分哪些任务应该在适当的 celery worker 中运行？现在两个应用程序的任务都安排在同一个工作人员中。其原因是 (?) CELERYBEAT_SCHEDULERto 'djcelery.schedulers.DatabaseScheduler'。我找不到任何不使用数据库的方法/调度程序。作为经纪人，我正在使用 redis（每个应用程序的本地/不同），因此来自 CELERYBEAT_SCHEDULE 之外的任务可以正常工作。

4

1 回答 1

0

您可以在设置中定义两个队列，并使用参数CELERY_QUEUES为每个 celerybeat 分配一个队列。--queues=queue1

您可以使用以下选项将任务分配给特定队列：

'options': {'queue': 'queue1'},
于 2015-11-24T13:13:21.997 回答