将芹菜任务保存在DB-Django中

Question

我指的是Django Celery文档。

正如文档所说，我在proj/proj中创建了celery.py。 然后包括__init__.py

celery.py

from __future__ import absolute_import
import os
from celery import Celery
from django.conf import settings
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'proj.settings')
app = Celery('proj')
app.conf.update(
    CELERY_RESULT_BACKEND='djcelery.backends.database:DatabaseBackend',
)
app.config_from_object('django.conf:settings')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)

__init__.py

from __future__ import absolute_import
from .celery import app as celery_app

我安装了pip install django-celery，然后迁移python manage.py migrate djcelery它在我的数据库中制作了一些表。

tasks.py

from __future__ import absolute_import
from celery import shared_task
import requests
import json
@shared_task
def post_notification(data,url):
    headers = {'content-type': 'application/json'}
    requests.post(url, data=json.dumps(data), headers=headers)

之后，我在视图中将我的任务称为

task = post_notification.delay(data,url)
print task.id #it prints an id
print task.status # prints PENDING

但是没有任何东西记录到我的任何表中。

我已经阅读了我在SO，Thread1，Thread2以及更多关于这些线程上的线程，但没有任何反应。

它为我提供了任务的ID和状态，但是如何将任务保存在数据库中？通常它应该登录到celery_taskmeta，但里面什么都没有。

虽然任务被执行，但我也想将任务保存在数据库中。我该怎么做？我错过了什么吗？

Answer 1

在 celery.py 中尝试这个

from __future__ import absolute_import
import os
from celery import Celery
from django.conf import settings
from celery.schedules import crontab
# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'app_name.dev_settings')
app = Celery('app_name')
# Using a string here means the worker will not have to
# pickle the object when using Windows.
app.config_from_object('django.conf:settings')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
app.conf.CELERY_TIMEZONE = 'UTC'
app.conf.update(
    CELERY_RESULT_BACKEND='djcelery.backends.database:DatabaseBackend',
)

Answer 2

在settings.py文件中添加以下内容

BROKER_URL = 'amqp://guest:guest@localhost//'
CELERY_ACCEPT_CONTENT = ['json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'

并启动工作线程。