Отменить задачу Celery с помощью SQS

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

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

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


python amazon-sqs celery kombu
person AlexA    schedule 21.03.2012    source источник
comment
У меня такая же проблема. Вы нашли решение?   -  person Lyle Pratt    schedule 16.04.2012
comment
Я вернулся к Django-Celery. Если вы не используете RabbitMQ, лучше придумать собственное решение для отзыва задач. Например. вместо выполнения задач постройте систему из двух компонентов: задача планировщика, которая сканирует вашу таблицу потенциальных задач и выполняет их, когда приходит время. Нет необходимости отзывать, вы просто можете решить не выполнять задачу, когда это необходимо.   -  person AlexA    schedule 16.04.2012

Ответы (1)


arrow_upward
1
arrow_downward

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

person AlexA    schedule 17.04.2012