Отмените задание из сельдерея с помощью SQS

Question

Я использую Celery + Kombu с Amazon SQL.Цель состоит в том, чтобы иметь возможность удалить задачу, уже запланированную на определенное время.Я пробовал

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

, но это ничего не изменило.Отзыв не реализован для транспорта SQS?За этим стоит какое-то дизайнерское решение или просто отсутствует функция, которая должна быть реализована какой-то строкой кода «DeleteMessage»?

Answer 1

Если вы не используете RabbitMQ, лучше придумать индивидуальное решение для отмены задач. Например. вместо выполнения задач создайте систему из двух компонентов: задачу планировщика, которая сканирует вашу таблицу потенциальных задач и выполняет их, когда придет время. Нет необходимости отзывать, вы просто можете решить не выполнять задачу при необходимости.