为什么 celery 后端不指向非本地主机的 ip 不工作？

Question

from celery import Celery

app = Celery('tasks', backend='amqp://guest@192.168.99.100', broker='amqp://guest@192.168.99.100//')


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

我可以成功发送 celery 任务，但是当我尝试获取任务结果时，它不会将它们发回。我认为这是由于后端 ip 被设置为外部 ip 而 celery 不尊重它造成的。

- ** ---------- .> transport:   amqp://guest:**@192.168.99.100:5672//
- ** ---------- .> results:     amqp://

以上是我运行'Celery -A workers.tasks worker --loglevel=debug'

时的输出

Answer 1

我不知道为什么会这样，但确实如此

运行带有 --pool=threads/solo 开关的命令

Celery -A proj.tasks worker -l info --pool=threads -n w1

为什么 celery 后端不指向非本地主机的 ip 不工作？

Why isn't a celery backend pointing to an ip that's not local host not working?

python

task

amqp

rabbitmq

celery