googleapis / googleapis/google-cloud-python

Expose StreamingPullManager.load property via StreamingPullFuture

未关闭
#15,634 2 条评论 0 个 reaction 已指派 1 人 已被 @abbrowne126 认领 在 GitHub 查看
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 还没有评估数据。

把新 issue 发到你的邮箱

精选适合新手参与的 GitHub issue 摘要。