googleapis / googleapis/google-cloud-python

Expose StreamingPullManager.load property via StreamingPullFuture

Đang mở
#15,634 2 bình luận 0 reaction 1 người được giao Được @abbrowne126 nhận Xem trên GitHub
api: pubsub
Ngôn ngữ chính
Python
Star
5.4k
Fork
1.8k
Merge trung bình
3 ngày 4 giờ
Pull request đã merge (30 ngày)
122

Mô tả

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

Hướng dẫn đóng góp

Mở hướng dẫn đóng góp

Đánh giá

Issue này chưa được đánh giá.

Nhận issue mới trong hộp thư của bạn

Bản tóm tắt ngắn những issue GitHub phù hợp với người mới.