Celery

Question

我正在使用 Django 1.10 + celery==4.0.0rc3 + django-celery with commit @79d9689b62db3d54ebd0346e00287f91785f6355 .

我的设置是：

CELERY_RESULT_BACKEND = 'djcelery.backends.database:DatabaseBackend'
CELERY_ACCEPT_CONTENT = ['json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TIMEZONE = TIME_ZONE
# http://docs.celeryproject.org/en/latest/getting-started/brokers/redis.html#visibility-timeout
BROKER_TRANSPORT_OPTIONS = {'visibility_timeout': 259200}  # 3 days

我的 tasks.py 我有

@task(queue='assign_rnal_id')
def assign_rnal_id_to_mongo(rnal_id, mongo_id):
    print ("something")

    return False

在我的 Django 模型中，我覆盖了保存方法以将任务发送到芹菜：

def save(self, *args, **kwargs):
    super(Suggested, self).save(*args, **kwargs)

        assign_rnal_id_to_mongo.delay(rnal_id=self.id, mongo_id=self.raw_data['_id'])

当我保存我的模型对象时，我得到一个 No module named 'celery.datastructures'

有什么想法吗？？我有类似的代码适用于旧版本的 django 和 celery，有什么变化吗？

谢谢

Answer 1

我能在这里找到答案https://github.com/celery/celery/issues/3303#issuecomment-246780116

基本上 Django-celery does not support 4.0 yet 所以我降级到 celery==3.1.23 现在可以使用了

Answer 2

使用 django 1.10 和 Celery 4。0.x我需要

pip install django-celery-results
pip install django-celery-beat

这解决了我的问题，无需降级我的 Celery。

Celery - 没有名为 'celery.datastructures' 的模块

Celery - No module named 'celery.datastructures'

python

django

django-celery