python - celery 节拍在同一时间间隔组下安排多个任务

Question

我正在尝试设置每分钟都运行的两个任务。有什么办法可以将它们组合在一起运行吗？

我在 celeryconfig.py 中指定了 CELERYBEAT_SCHEDULE，如下所示:

CELERYBEAT_SCHEDULE = {
    'every-minute': {
        'task': 'tasks.add',
        'schedule': crontab(minute='*/1'),
        'args': (1,2)
    },
}

所以如果我想运行两个任务，我会期待这样的事情吗？

CELERYBEAT_SCHEDULE = {
    'every-minute': {
        'task': ['tasks.add','task.multiply'],
        'schedule': [crontab(minute='*/1'),crontab(minute='*/1')],
        'args': [(1,2),(3,4)]
    },
}

然而它并没有起作用。有什么标准的方法可以做到这一点吗？

Answer 1

Celery Documentation: Periodic Tasks声明你只能有要执行的任务的名称(不是列表等)

您可以创建两个不同的日程表条目:

CELERYBEAT_SCHEDULE = {
    'every-minute_add': {
        'task': 'tasks.add',
        'schedule': crontab(minute='*/1'),
        'args': (1,2)
    },
    'every-minute_multiply': {
        'task': 'task.multiply',
        'schedule': crontab(minute='*/1'),
        'args': (3,4)
    },
}