6

所以我刚刚开始使用芹菜并尝试做一些简单的测试来感受它。我试图设置一个芹菜来为我的后端使用 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 构造函数中取出后端参数可以按预期工作。
我在这里做错了什么？我觉得这一定很愚蠢，因为我在网上找不到任何东西。

提前致谢。

4

2 回答 2

16

答案就在这里http://celery.readthedocs.org/en/latest/configuration.html#database-url-examples

您需要在常规 SQL Alchemy url 字符串前面加上db+，例如

CELERY_RESULT_BACKEND = "db+postgresql+psycopg2://..."
于 2014-07-14T16:52:25.493 回答
0

Celery 获取您传递给它的 URL，查看前缀（在本例中为“sqla+postgresql”）并查找与之匹配的后端。仅使用数据库就没有“通用”加载后端。您可以检查系统上 celery 文件夹中的 backend/ init .py 以查看整个别名字典，然后添加您自己的。

于 2013-06-25T17:39:42.660 回答