Отправить сообщение задачи сельдерея rabbitmq - PullRequest
Новая
       13

Отправить сообщение задачи сельдерея rabbitmq

0 голосов
/ 02 ноября 2018

Я обычно использую сельдерей с Django и запускаю общие задачи в Django.

Но для конкретного случая я хочу добавить очередь задач в rabbitmq вручную без запуска Django или celerybeat.

Есть ли какой-нибудь простой Python-скрипт или командная оболочка для этого?

1 Ответ

0 голосов
/ 04 ноября 2018

Вы можете использовать метод send_task , чтобы поставить задачу в очередь произвольному посреднику с сельдереем. Но вам нужно знать имя приложения и URL брокера, чтобы вы могли отправить задачу в нужное место. 


from celery import Celery

app = Celery('app_name', broker='pyamqp://guest@localhost//')
app.send_task('namespace.my_task', kwargs={
    'arg1': 'value1',
    'arg2': 'value2',
})
...