googleapis / googleapis/google-cloud-python

Expose StreamingPullManager.load property via StreamingPullFuture

オープン
#15,634 コメント 2 件 リアクション 0 件 担当者 1 名 @abbrowne126 が担当を希望しています GitHub で見る
api: pubsub
主要言語
Python
スター
5.4k
フォーク
1.8k
平均マージ
3日 4時間
マージ済み PR(30日)
122

説明

**Is your feature request related to a problem? Please describe.**
When implementing custom scaling mechanisms in worker-pool workloads, the only current working solution is to count active messages. This is cumbersome and also doesn't account for other reasons why a particular worker may be close to its limits. Using monitoring metrics is not always feasible and imposes longer aggregation periods.

**Describe the solution you'd like**
A public property on `StreamingPullFutire` that provides read-only getter to `__manager.load`

**Describe alternatives you've considered**
Counting total active messages and their cumulative size manually in code.

コントリビューションガイド

コントリビューションガイドを開く

評価

この issue はまだ評価されていません。

新しい issue をメールで受け取る

初心者向けの GitHub issue を短くまとめたダイジェスト。