使用Postgres作为代理设置芹菜-没有这样的传输“db”

Question

我目前正试图让postgres成为芹菜的经纪人:

broker = "db+postgresql://guest:guest@postgres-localnet/test_db"
app = Celery('tasks', broker=broker)

@app.task
def add(x, y):
    return x + y

当我尝试添加消息/任务时：

>>> import app.tasks as t
>>> t.add.delay(1,2)

我得到以下错误消息:

  File "/usr/local/lib/python3.6/site-packages/kombu/transport/__init__.py", line 64, in resolve_transport
    raise KeyError('No such transport: {0}'.format(transport))
KeyError: 'No such transport: db'

根据文件(http://docs.celeryproject.org/en/latest/userguide/configuration.html#database-url示例），看起来这应该有效。

我在这里做错了什么？

Answer 1

从芹菜4.2开始，您不能使用数据库作为代理。根据文档，仅支持四个代理:

< li>redis < li>rabbitmq < li>sqs 动物园管理员

对于昆布级运输，您可以参考此参考。