1

我正在使用 Celery 处理我的烧瓶应用程序中的后台任务，但我无法使其与 CloudAMQP 一起使用

celery = Celery(app.name, broker=app.config["BROKER_URL"],
            backend="amqp://"
            )

代理 urlamqp://ali:**@127.0.0.1:5672// 用于本地使用和amqp://name:password@moose.rmq.cloudamqp.com/name生产

我尝试在本地使用 CloudAMQP，这是日志

[2016-03-22 16:47:16,919: INFO/MainProcess] Connected to amqp://name:password@moose.rmq.cloudamqp.com/name
[2016-03-22 16:47:16,937: INFO/MainProcess] mingle: searching for neighbors
[2016-03-22 16:47:17,958: INFO/MainProcess] mingle: all alone
[2016-03-22 16:47:17,989: WARNING/MainProcess] celery@alidesktop ready.

之后什么也没有发生；任务未执行，但在我返回本地代理 url 后，排队的任务正常执行。

4

0 回答 0