Я использую Celery + Kombu с Amazon SQL. Цель состоит в том, чтобы убрать задачу, запланированную на какое-то определенное время. Я попыталсяЗадача об отзыве сельдерея с SQS
from celery.task.control import revoke
revoke(task_id)
, но это ничего не меняет. Отменяется ли отказ в транспортировке SQS? Есть ли какое-то дизайнерское решение, или это просто недостающая функция, которая должна быть реализована какой-то линией кода «DeleteMessage»?
У меня такая же проблема. Вы нашли решение? –
Я вернулся к Django-Celery. Если вы не используете RabbitMQ, лучше придумать специальное решение для отзыва задач. Например. вместо выполнения задач создайте систему из двух компонентов: задачу планировщика, которая сканирует вашу таблицу потенциальных задач и выполняет их при необходимости. Не нужно отменять, вы просто можете решить не выполнять задачу, когда это необходимо. – AlexA