python - 如何在芹菜中设置回调

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) 

除了 lambda，它可以是任何未在 celery 任务中定义但从中调用任务的函数。

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 并且几乎可以编写普通代码。