python - Celery Python 中的异步子任务

Question

我需要将 celery 中的子任务异步调用到另一个工作人员(在另一台机器上)，如下所示:

#db.py
@task()
def query(x,y):
   ...something
   return z

#worker2.py
@task()
def main(x,y):
   result=db.query.async((x,y), queue='db')
   try:
       a=result.get(timeout=5)
   except celery.exceptions.TimeoutError:
       ....

但是我在启动工作程序时收到警告:运行时警告:切勿在任务中调用 result.get()!

如何从另一个任务调用异步任务？我不会使用链条、弦等。

Answer 1

您永远不想阻止一项任务来等待另一项任务，因此正确的方法是使用 chain :

db.py
@task()
def query(x, y):
   ...something
   return z

#worker2.py
@task()
def main(resultFromQuery, x, y):
   a = resultFromQuery.get(timeout=5)
   ...

res = chain(query.s(x,y), main.s(x,y));
res.get()