我有一个XMPP聊天机器人,它接收命令并回复命令。我有一个使用Celery处理命令的任务队列,我希望机器人在命令返回时回复。然而,每当每个任务完成时,我都找不到执行函数的好方法。
例如,像这样的东西会很好:
for result in queue.get_result():
send_message(result)
然而,我找不到任何关于如何做到这一点的信息。有人知道吗?
看看http://ask.github.com/celery/reference/celery.result.html#celery.result.ResultSet
每个任务都应该负责返回用户。