如何在芹菜中创建子任务

2024-06-26 14:42:28 发布

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

我试图在我的数据库中循环许多buildings。在每栋大楼里,我为每一个apt生成一张账单。这一切都发生在每月25号的预定任务上。账单下个月寄出。我知道我可以使用chordsgroups和其他子任务,我只是不知道如何将它组织成一个巨大的工作机制。这就是我目前为止所做的(但不起作用)。我正在使用crontab和当前时间进行测试,这样我就可以看到它运行了。在生产中,我会把日期定在每月25号。在

配置.py

CELERY_TIMEZONE = 'America/New_York'
CELERYBEAT_SCHEDULE = {
    "billing-schedule": {
        "task": "tasks.bill_all_buildings",
        "schedule": crontab(hour=8,minute=41)
    },
}

任务.py

^{pr2}$

发生的情况是bill_all_buildings运行,然后它说:

[2014-01-31 07:28:00,036: DEBUG/MainProcess] Task accepted: tasks.bill_apts_in_building[da7b46f2-e559-4947-9442-bd31329d8d0d] pid:9156

然后什么也没发生。在


Tags: py数据库时间aptall机制tasksgroups