芹菜定期任务作为asnyc on djang

2024-09-28 05:23:22 发布

您现在位置:Python中文网/ 问答频道 /正文

我不擅长英语,所以如果你听不懂我的句子,请给我任何意见。在

我用芹菜来做django的定期任务。在

CELERYBEAT_SCHEDULE = {
    'send_sms_one_pm': {
        'task': 'tasks.send_one_pm',
        'schedule': crontab(minute=0, hour=13),
    },
    'send_sms_ten_am': {
        'task': 'tasks.send_ten_am',
        'schedule': crontab(minute=0, hour=10),
    },
    'night_proposal_noti': {
        'task': 'tasks.night_proposal_noti',
        'schedule': crontab(minute=0, hour=10)
    },
}

这是我的芹菜时间表,我用redis来排队。在

问题是,当最大的任务开始时,其他任务被搁置。 最大的任务将处理10小时,其他任务将在10小时后启动。在

我的任务看起来像

^{pr2}$

我找到了,芹菜给我task.apply_asnyc应用(),但找不到可以在asnyc上工作的定期任务。在

所以,我想知道芹菜的周期性任务可以作为asnyc任务。我的芹菜工人是8个工人。在


Tags: sendtaskamsmsonetasks芹菜schedule
1条回答
网友
1楼 · 发布于 2024-09-28 05:23:22

您是否也在设置中分配^{cd1>}? 如果希望一个任务开始在另一个任务之后运行,那么应该使用^{{cd2>}与链接^{{cd3>}一起运行,看起来如下:

res=[signature(your_task.name, args=(...), options=kwargs, immutable=True),..]
task.apply_async((args), link=res)

相关问题 更多 >

    热门问题