djceleri:如何将芹菜任务状态保存到数据库中

2024-06-25 23:30:12 发布

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

我的芹菜任务运行良好
但我发现我的djcelery_taskstate表中没有任何内容:
enter image description here

它如何将数据保存到其中??在

以下是我的设置:

settings.py

BROKER_URL = 'redis://localhost:6379'
CELERYBEAT_SCHEDULER = 'djcelery.schedulers.DatabaseScheduler'  
CELERY_RESULT_BACKEND = 'djcelery.backends.database:DatabaseBackend'
CELERY_TIMEZONE = 'Asia/Taipei'

celery.py

^{pr2}$

tasks.py

from __future__ import absolute_import
from celery.task.schedules import crontab
from celery.decorators import periodic_task
from celery import task
from datetime import timedelta
from myapp.deal import check_data


@periodic_task(run_every=timedelta(seconds=30),name="collect-rawdata",ignore_result=True)
def rawdata():
    return check_data()

下面是我管理芹菜的命令:

一次终端运行:

celery -A wiarea worker -l info

另一次跑步:

celery -A wiarea beat -l info 

Tags: frompyimportinfotaskdatachecktimedelta