Celery : 브로커 연결 풀에 액세스

Question

AMQP 중개자와 함께 Celery를 사용하여 작업을 호출하지만 Celery가 사용하는 것과 다른 큐 구조로 응답을 전달해야하므로 Kombu를 사용하여 메시지를 다시 전달하려고합니다. 만. 나는 이것을 할 수 있었지만 매번 새로운 연결을 만들고있다. Celery는 브로커 연결 풀을 사용합니까? 그렇다면 어떻게 액세스합니까?

Answer 1

셀러리의 문서가 ... 멋진 ...하지만 나는 found 대답 때문에 검색이 많이 걸렸습니다.

셀러리는 하위 작업 호출을 위해 브로커 연결 풀을 사용합니다. 셀러리 응용 프로그램의 경우 pool attribute이 있으며 <your_app>.pool 또는 celery.current_app.pool을 통해 액세스 할 수 있습니다. 그런 다음 pool.acquire()을 사용하여 풀에서 연결을 가져올 수 있습니다.