2012-03-21 9 views
4

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

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

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

+0

У меня такая же проблема. Вы нашли решение? –

+0

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

ответ

1

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

 Смежные вопросы

  • Нет связанных вопросов^_^