如何在 celery 中设置回调

Question

我想向函数添加回调，以便在它返回时可以调用常规的 python 函数，

我的任务

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

我想如何使用它：

from __future__ import print_function
delay.add(2, 3 ,callback=lambda x: print x) 

它可以是任何未在 celery 任务中定义但从哪里调用任务的函数，而不是 lambda。

Answer 1

在这种情况下您只能链接任务：

add.apply_async((2, 3), link=other_task.s())

与以下内容相同：

(add.s(2, 3) | other_task.s())()

等待任务完成使任务同步，因此您想要的调用相当于：

(lambda x: print(x))(add.delay(2, 3).get())

这将阻塞当前进程，直到任务返回。如果您不希望进程阻塞，那么您必须编写一个专用线程来等待结果并调用回调。

或者您可以使用 eventlet/gevent 并编写几乎正常的代码。