这是我与芹菜(芹菜4.1,python 3,django 1.10)的第一天。我正在执行一个简单的任务,将记录插入我的主数据库中。奇怪的是,我没有收到错误消息,但是记录只是在数据库中没有插入。这是代码:
views.py:
def test_view(request):
test.delay()
return HttpResponse()
tasks.py
from __future__ import absolute_import, unicode_literals
from celery import task
from main.models import EmailDialog
@task()
def test():
a = EmailDialog()
a.save()
如果我删除.delay()
并将test()
称为标准Python函数,我会看到记录出现在数据库中。但是添加了.delay()部分后,未添加记录。我想知道要挖什么方向。
P.S。我看到了一个类似的问题,但也没有帮助解决问题。
如果没有开始,请开始芹菜工人。检查所有芹菜配置是否按照文档完成。并检查是否提供了消息经纪。