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

Question

我正在使用 Django 1.10 + celery==4.0.0rc3 + django-celery 并提交 @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.datastructs'

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

谢谢

Answer 1

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

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

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