使用SQS撤消Celery任務

我正在使用Celery + Kombu和Amazon SQL。目標是能夠刪除已安排的某個特定日期時間的任務。我試了使用SQS撤消Celery任務

from celery.task.control import revoke 
revoke(task_id)

但這並沒有改變任何東西。是否撤銷SQS傳輸？是否有一些背後的設計決定，或者它只是一個缺乏的功能，應該由一些「DeleteMessage」代碼行來實現？

來源

2012-03-21 AlexA

我遇到同樣的問題。你找到解決方案嗎？ – 2012-04-16 15:21:56

我已經恢復到Django-Celery。除非你使用RabbitMQ，否則最好爲自己的任務提供一個定製的解決方案。例如。不是執行任務，而是建立一個由兩部分組成的系統：調度程序任務，用於掃描您的潛在任務表並在時間到期時執行它們。無需撤銷，您可以決定在需要時不執行任務。 – AlexA 2012-04-16 19:39:34

除非您使用的是RabbitMQ，否則最好提供一個用於撤銷任務的自定義解決方案。例如。不是執行任務，而是建立一個由兩部分組成的系統：調度程序任務，用於掃描您的潛在任務表並在時間到期時執行它們。無需撤銷，您可以決定在需要時不執行任務。

來源

2012-04-17 14:23:40 AlexA

使用SQS撤消Celery任務

回答

相關問題