我如何處理芹菜的任務結果？

我有一個XMPP聊天機器人，它接收命令並回復它們。我有一個使用Celery處理命令的任務隊列，並且我希望機器人在命令返回時回覆。但是，無論何時每個任務完成，我都找不到一種執行功能的好方法。我如何處理芹菜的任務結果？

例如，這樣的事情將是很好：

for result in queue.get_result(): 
    send_message(result)

但是，我無法找到如何做到這一點的任何信息。有人知道嗎？

2012-02-14 03:02:29

這似乎並不奏效。迭代（）不會永遠阻止，但我可以使用區間來解決這個問題。但是，刪除結果只會產生KeyError。順便說一下，結果是一個雙字符串元組。 – 2012-02-14 03:35:17

我不會認爲它應該永遠封鎖，我一直以爲你會想在你的聊天機器人的運行循環中使用類似的東西。 – 2012-02-14 03:38:56

運行循環運行在一個單獨的線程中，所以我可以在主線程中運行一些東西。另外，運行循環是在一個單獨的庫中，所以我不認爲我可以觸摸它...但KeyError問題仍然存在。 – 2012-02-14 03:42:09

每個任務應該負責找回用戶。

2012-02-14 04:13:44 PanosJee

這是不可能的，不幸的是，我不能編組負責發送消息的班級...... – 2012-02-14 12:00:17

回答