2013-11-14 46 views
5

我正在使用Celery和AMQP代理來調用任務,但響應需要傳回與Celery使用的不同隊列體系結構,因此我想使用Kombu將消息傳回給客戶只要。我已經能夠做到這一點,但我每次都創建一個新的連接。 Celery是否使用經紀人連接池,如果是,您如何訪問它?芹菜:訪問代理連接池

回答

10

它花了很多搜索,因爲芹菜的文檔是... 精彩 ...但我found的答案。

Celery確實使用代理連接池來調用子任務。芹菜應用程序有一個pool attribute,您可以通過<your_app>.poolcelery.current_app.pool訪問。然後您可以使用pool.acquire()從池中獲取連接。

+0

我處於類似的情況。以下代碼是否正確 - http://dpaste.com/2SSJ8W0?我感謝任何幫助。謝謝! – avi