Запрос на блокировку удаленного задания Celery - PullRequest
Новая
       21

Запрос на блокировку удаленного задания Celery

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

У меня проблема с удаленным вызовом задачи через приложение торнадо с вызовом REST. В моем случае у меня есть задачи, которые работают на другой машине, а остальные API остальных работают на другой машине. 

 from flask import Flask 

 celery_obj = //CELERY .

 @app.route("/task1")
 def func():
     celery_obj.send_task(name="tasks.task1", args=[])

Когда я запускаю приложение и отправляю запрос конечной точке / taksk1, приложение фляги не может ничего ответить.

В чем причина этой проблемы. Пожалуйста помоги.

1 Ответ

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

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

например., 


from celery.app import Celery
celery = Celery(broker='redis://127.0.0.1/1')
celery.send_task('task.name', kwargs={})
...