我想向函数添加回调,以便在返回时可以调用常规的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并编写通常的代码.
标签：celery,python 来源： https://codeday.me/bug/20191127/2075760.html
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。