어떻게 rabbitmq 대기열에 이미있는 작업을 실행하려면 셀러리와 장고를 사용합니까?

Question

이 시점에서 나는 대부분 rabbitmq 문서와 셀러리 문서 및 google soo를 여러 번 읽었습니다. 필자는 필자가 필요로하는 정보를 어디에서나 찾을 수 없습니다.

필자는 비틀어 진 웹 서버에 전달 된 메시지를 읽고 pika를 사용하여 메시지를 대기열에 넣습니다. 그건 잘 작동합니다. 내가 겪고있는 문제는 내가 여기서하는 일이다. 일어날 일은 주기적으로 (셀리 비트를 사용하여) 현재 대기열에있는 것을 소비하려고합니다. 큰 문제는 내가 샐비어 (또는 셀러리 비트)가 완료 할 작업을 할당 할 수 있도록 rabbitmq에 작업을 전달하는 방법을 모른다는 것입니다.

이 질문을하는 가장 쉬운 방법은 다음과 같습니다. 데이터를 본문으로 갖는 대기열을 읽고 장고에서 해당 데이터를 사용할 수 있습니까?

도움을 주시면 감사하겠습니다.

Answer 1

내가이 어떤 도움이 경우 잘 모르겠지만, 내가 장고에서 대기 작업 djcelery를 사용,이 토끼 MQ에

별도의 파이썬 manage.py를 큐 (celeryd | celerybeat) 프로세스가 대기중인 집어 들고 장고의 설정에 따라 작업이

https://github.com/ask/django-celery

Answer 2

나는 같은 질문이 생각하지만, 내가 그것을 확인하기 위해 다시 언급하자 :

당신이 셀러리 t을 사용할 수 o Django가 아닌 다른 Celery 프로세스가 RabbitMQ에 넣은 메시지를 소비합니까? 예를 들어, 구매가 이루어질 때 자바 시스템이 RabbitMQ에 메시지를 보내면 Celery 태스크가 해당 메시지에 응답하고 조치를 취할 수 있습니까?