問題タブ [flower]

質問する

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

174 問題

0 投票する

1 に答える

884 参照

python - セロリワーカーの処理タスクを停止するか、Flower で「未使用」のタスクを監視します

セロリキューのすべてのタスクがサードパーティの API にヒットしているとします。ただし、API にはレート制限があり、私はそれを追跡しています (尊重する必要がある 1 日あたりの制限と 1 時間あたりの制限があります)。レート制限に達するとすぐに、新しいタスクの使用を一時停止し、問題がないことがわかったら再開したいと考えています。

次の2つのタスクを使用してこれを達成しました。

その後、サードパーティの API タスクを送信し続けることができ、コンシューマーが追加されるとすぐに、すべてのタスクが消費されます。偉大な。

ただし、このキューにはコンシューマーがいないため、 Flowerで送信されているジョブを(コンシューマーが追加されるまで)見ることができないようです。

私が間違っていることはありますか？この「一時停止」を別の方法で実行して、送信されたジョブが引き続き表示されるようにすることはできますか?

PSおそらくこれはこの問題に関連していますが、100％確実ではありません：https://github.com/celery/celery/issues/1452

それが違いを生む場合、私はamqpブローカーを使用しています。

女の子と男の子に感謝します。