googleapis / googleapis/google-cloud-python
Expose StreamingPullManager.load property via StreamingPullFuture
未关闭
api: pubsub
- 主要语言
- Python
- 星标
- 5.4k
- 派生
- 1.8k
- 平均合并
- 3 天 4 小时
- 30 天内合并 PR
- 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 还没有评估数据。