到目前为止，我只处理过定义为函数的 Celery 任务。我曾经定义它们的周期性CELERYBEAT_SCHEDULE范围。像这样：
from datetime import timedelta
CELERYBEAT_SCHEDULE = {
'add-every-30-seconds': {
'task': 'tasks.add',
'schedule': timedelta(seconds=30),
'args': (16, 16)
},
}
现在我尝试使用基于类的任务，如下所示：
class MyTask(Task):
"""My Task."""
def run(self, source, *args, **kwargs):
"""Run the celery task."""
logger.info("Hi!")
我的问题是：如何定义基于类的任务的定期执行？
None
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
