셀러리없이 셀러리 작업에 회신하려면 어떻게해야합니까?

Question

셀러 리를 사용하여 Java 작업자에게 작업을 보내고 있습니다. 작업자는 셀러리를 사용하지 않지만, 작업 이름, args 등을 얻기 위해 json 요청을 구문 분석 할 수있을 정도로 문서가 명확합니다. 이제 요청에 응답하려고합니다. 나는 회신을 task.properties.reply_to이라는 이름으로 대기열에 집어 넣는 것만 큼 쉽지만 생각하지는 않습니다.

작업에 회신하려면 어떻게해야합니까?

현재 BT는 브로커와 백엔드 모두에 redis를 사용하고 있습니다.

감사합니다.

Answer 1

셀러리의 WebHook interface을 사용 해본 적이 있습니까? 이는 다른 언어로 작성된 시스템이 Celery 태스크를 실행할 수 있도록 설계되었습니다.

장고 예 :

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')