googleapis / googleapis/google-cloud-python

Expose StreamingPullManager.load property via StreamingPullFuture

Offen
#15,634 2 Kommentare 0 Reaktionen 1 zugewiesene Person Beansprucht von @abbrowne126 Auf GitHub ansehen
api: pubsub
Vorherrschende Sprache
Python
Sterne
5.4k
Forks
1.8k
Ø Merge
3 T. 4 Std.
Gemergte PRs (30 T.)
122

Beschreibung

**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.

Beitragsleitfaden

Beitragsleitfaden öffnen

Bewertung

Dieses Issue wurde noch nicht bewertet.

Neue Issues direkt in Ihr Postfach

Eine kurze Übersicht über anfängerfreundliche GitHub-Issues.