我正在使用Django 1.10
+ celery==4.0.0rc3
+ django-celery with commit @79d9689b62db3d54ebd0346e00287f91785f6355
。芹菜 - 沒有名爲'celery.datastructures'的模塊
我的設置是:
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和芹菜工作,做了一些改變?
感謝
現在應該是正確的答案。 – psychok7
您是否知道是否有方法監控這些軟件包的Worker狀態? – psychok7