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
当我无法将任务的结果发送回芹菜时,我尝试将其发送回。我认为这是由于后端ip被设置为外部ip和芹菜不尊重这一点。你知道吗
- ** ---------- .> transport: amqp://guest:**@192.168.99.100:5672//
- ** ---------- .> results: amqp://
上面是我运行“芹菜-A”时的输出工人.任务worker--loglevel=debug'
我不知道这到底是为什么,但它确实起作用了
使用pool=threads/solo开关运行命令
芹菜-A项目任务worker-l info pool=线程-n w1
相关问题 更多 >
编程相关推荐