Celery: accesso al pool di connessione del broker

Question

Utilizzo di Celery con un broker AMQP per chiamare attività, ma la risposta deve essere restituita con un'architettura di coda diversa da quella utilizzata da Celery, quindi voglio passare nuovamente i messaggi utilizzando Kombu solo. Sono stato in grado di farlo, ma sto creando una nuova connessione ogni volta. Celery utilizza un pool di connessioni broker e, in caso affermativo, come si accede?

Answer 1

Ci sono volute molte ricerche perché la documentazione di Celery è ... meraviglioso ... ma io found la risposta.

Celery utilizza un pool di connessioni broker per la chiamata di attività secondarie. L'applicazione di sedano ha un numero pool attribute a cui è possibile accedere tramite <your_app>.pool o celery.current_app.pool. È quindi possibile prendere una connessione dal pool utilizzando pool.acquire().