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

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模型中，我重写了save方法来向celery发送一个任务：

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

使用django 1.10和Celery 4.0.x，我需要

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

这解决了我的问题，而不需要降级我的芹菜。

Answer 2

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

基本上是Django-celery does not support 4.0 yet，所以我降级到了celery==3.1.23，现在它可以工作了