Как ответить на задание сельдерея без сельдерея?

Question

Я использую сельдерей для отправки задания работнику Java. Рабочий не использует сельдерей, но документы были достаточно ясными, чтобы я мог разобрать запрос json, чтобы получить имя задачи, аргументы и т. Д. Теперь я пытаюсь ответить на запрос. Я думал, что это может быть так же просто, как вставить ответ в очередь с именем task.properties.reply_to, но это не работает.

Как вы отвечаете на задание?

BTW, я использую redis для брокера и бэкэнд.

Спасибо.

Answer 1

Рассматривали ли вы использование Celery's WebHook interface. Это предназначено, чтобы позволить системам, написанным на других языках, выполнять задачи Сельдерея.

Джанго пример:

from django.http import HttpResponse 
from anyjson import serialize 


def multiply(request): 
    x = int(request.GET['x']) 
    y = int(request.GET['y']) 
    result = x * y 
    response = {'status': 'success', 'retval': result} 
    return HttpResponse(serialize(response), mimetype='application/json')