因此,我只是开始使用芹菜,并尝试做一些简单的测试来感受一下它。我正在尝试设置一个芹菜来使用postgres作为我的后端。在此页面上:
http://docs.celeryproject.org/en/latest/getting-started/first-steps-with-celery.html#keeping-results我看到了这个例子
celery = Celery('tasks', backend='redis://localhost', broker='amqp://')因此在我的代码中,我尝试
celery = Celery('tasks',
backend='sqla+postgresql://celery_exp:celery_exp@myhost/celery_exp',
broker='sqla+postgresql://celery_exp:celery_exp@myhost/celery_exp',)但是当我启动它的时候,我一直收到这个错误:
ImportError: No module named sqla+postgresql在文档中,我尝试了不同的变体,例如
postgresql://
postgresql+psycopg2:// 我知道连接字符串是正确的,因为在Celery构造函数中去掉后端参数可以正常工作。
我在这里做错了什么?我觉得这一定是什么愚蠢的事情,因为我在网上找不到任何东西。
提前谢谢。
发布于 2014-07-15 00:52:25
答案就在这里http://celery.readthedocs.org/en/latest/configuration.html#database-url-examples
您需要在常规SQL Alchemy url字符串前面加上db+,例如
CELERY_RESULT_BACKEND = "db+postgresql+psycopg2://..."发布于 2013-06-26 01:39:43
Celery获取您传递给它的URL,查看前缀(在本例中为"sqla+postgresql"),并查找与之匹配的后端。只有数据库没有“通用”加载后端。您可以检查系统上celery文件夹中的backend/init.py以查看整个别名字典,然后添加您自己的别名字典。
https://stackoverflow.com/questions/14635673
复制相似问题