mongodb - Celery の mongoDB ブローカーはポーリングで動作しますか?

Question

mongoDB ブローカーの Celery のドキュメントには、ポーリングによって機能するかどうかは記載されていません。このブログ投稿で、mongoDB で pub/sub が可能であると読みましたが、Celery の mongoDB ブローカーがそれを行うかどうかはわかりません。

2 つのサブ質問:

1. ブローカーがポーリングによって動作する場合、頻度はどのくらいですか? また、どのように設定すればよいですか?
2. ブローカがテーラブル カーソルで動作する場合、シャーディングと互換性がありますか (キュー名による)。

どうもありがとう。

Answer 1

ソース コードをのぞき見しました。Celery は Kombu に基づいており、 mongoDB トランスポート ソース コード ( kombu.transport.mongodb) から判断すると、drain_eventsメソッドは単純にクラスから継承され、kombu.transport.virtual.Transport毎秒単純にポーリングされます。

polling_intervalトランスポート オプションで属性を設定することにより、ポーリング間隔をオーバーライドできます(この commit を参照)。