5
我正在使用Celery和AMQP代理來調用任務,但響應需要傳回與Celery使用的不同隊列體系結構,因此我想使用Kombu將消息傳回給客戶只要。我已經能夠做到這一點,但我每次都創建一個新的連接。 Celery是否使用經紀人連接池,如果是,您如何訪問它?芹菜:訪問代理連接池
我正在使用Celery和AMQP代理來調用任務,但響應需要傳回與Celery使用的不同隊列體系結構,因此我想使用Kombu將消息傳回給客戶只要。我已經能夠做到這一點,但我每次都創建一個新的連接。 Celery是否使用經紀人連接池,如果是,您如何訪問它?芹菜:訪問代理連接池
它花了很多搜索,因爲芹菜的文檔是... 精彩 ...但我found的答案。
Celery確實使用代理連接池來調用子任務。芹菜應用程序有一個pool
attribute,您可以通過<your_app>.pool
或celery.current_app.pool
訪問。然後您可以使用pool.acquire()
從池中獲取連接。
我處於類似的情況。以下代碼是否正確 - http://dpaste.com/2SSJ8W0?我感謝任何幫助。謝謝! – avi