Celery：ブローカ接続プールへのアクセス

Question

AMQPブローカでCeleryを使用してタスクを呼び出すが、Celeryが使用するキューアーキテクチャとは異なるキューアーキテクチャで応答を返す必要があるため、Kombuを使用してメッセージを返送したいのみ。私はこれを行うことができましたが、毎回新しい接続を作成しています。 Celeryはブローカー接続プールを使用していますか？そうであれば、どのようにアクセスしますか？

Answer 1

セロリのドキュメントは... すばらしい ...でも私はfoundと答えているので、たくさんの検索が必要でした。

セロリはサブタスクの呼び出しにブローカ接続プールを使用します。セロリアプリケーションには、<your_app>.poolまたはcelery.current_app.poolでアクセスできるpool attributeがあります。その後、pool.acquire()を使用してプールから接続を取得できます。