我想向函数添加回调,以便在返回时可以调用常规的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,它可以是芹菜任务中未定义的任何函数
但是从哪里调用任务.

解决方法:

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

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并编写通常的代码.