python - SQS で Celery タスクを取り消す

Question

Amazon SQL で Celery + Kombu を使用しています。目標は、特定の日時にすでにスケジュールされているタスクを削除できるようにすることです。私はもう試した

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

しかし、それは何も変わりませんでした。SQS トランスポートの取り消しは実装されていませんか? その背後に何らかの設計上の決定があるのでしょうか、それともコードの「DeleteMessage」行によって実装されるべき機能が欠けているだけなのでしょうか?

Answer 1

RabbitMQ を使用していない限り、タスクを取り消すためのカスタム ソリューションを考え出すことをお勧めします。たとえば、タスクを実行する代わりに、次の 2 つのコンポーネントからなるシステムを構築します。潜在的なタスクのテーブルをスキャンし、時間が来たらそれらを実行するスケジューラ タスクです。取り消す必要はありません。必要なときにタスクを実行しないことを決定できます。