2

我正在使用 Django 和 RabbitMQ 运行 Celery，并希望查看数据库表中的任务状态。不幸的是，表 djcelery_taskstate 中没有写入任何条目，我不知道为什么。

我的设置：

CELERY_ENABLE_UTC = True
BROKER_URL = "amqp://guest:guest@localhost:5672/"
CELERY_RESULT_BACKEND = "database"
CELERYBEAT_SCHEDULER = 'djcelery.schedulers.DatabaseScheduler'

CELERY_TRACK_STARTED = True
CELERY_SEND_EVENTS = True

CELERY_IMPORTS = ("project_management.tasks", "accounting.tasks", "time_tracking.tasks", )
CELERY_ALWAYS_EAGER = False

import djcelery
djcelery.setup_loader()

我的任务：

class TestTask(Task):

    def run(self, po_id):
        self.update_state(state=states.STARTED, meta={'total': 0, 'done': False})
        #do something..
        self.update_state(state=states.SUCCESS, meta={'total': 100, 'done': True})

我在视图中按以下方式开始任务：

TestTask.apply_async(args=[], kwargs={})

我正在按如下方式开始芹菜工人。

python manage.py celeryd -v 1 -B -s celery -E -l INFO

控制台给了我以下输出：

[2013-05-19 11:10:03,774: INFO/MainProcess] Task accounting.tasks.TestTask[5463b2ed-0eba-451d-b828-7a89fcd36348] succeeded in 0.0538640022278s: None

知道我的设置有什么问题吗？

4

1 回答 1

2

您还需要启动快照相机才能在数据库中查看结果。

python manage.py celerycam

运行该程序后，您将能够看到表中的条目djcelery。

于 2013-05-19T12:28:34.113 回答