Pubsub 以稳定的速度拉取？
Pubsub pull at a steady rate?
有没有办法使用 google-cloud-pubsub 客户端强制执行稳定的轮询率？。我想避免如果发布率出现峰值，拉取请求率也会增加的情况。
客户端通过设置maxOutstanding消息提供FlowControl设置。据我了解，它在拉取操作期间设置了最大批量大小。
我想了解如何创建恒定的拉取率，比如 1000 RPS。
Message Flow Control 可用于设置在给定时间处理的最大消息数（即，在 python 客户端的情况下设置 max_messages），这间接设置接收消息的最大速率。
虽然它不允许您直接设置每秒接收的确切消息数（这取决于处理消息所需的时间和正在处理的消息数），但它应该避免出现峰值的情况发布率。
如果您确实需要设置每秒接收消息的速率，据我所知，它不能直接在客户端库上提供，因此您必须使用 asynchronous pull 和一些计时器自行实现以您想要的速度确认消息。
有没有办法使用 google-cloud-pubsub 客户端强制执行稳定的轮询率？。我想避免如果发布率出现峰值，拉取请求率也会增加的情况。
客户端通过设置maxOutstanding消息提供FlowControl设置。据我了解，它在拉取操作期间设置了最大批量大小。
我想了解如何创建恒定的拉取率，比如 1000 RPS。
Message Flow Control 可用于设置在给定时间处理的最大消息数（即，在 python 客户端的情况下设置 max_messages），这间接设置接收消息的最大速率。 虽然它不允许您直接设置每秒接收的确切消息数（这取决于处理消息所需的时间和正在处理的消息数），但它应该避免出现峰值的情况发布率。
如果您确实需要设置每秒接收消息的速率，据我所知，它不能直接在客户端库上提供，因此您必须使用 asynchronous pull 和一些计时器自行实现以您想要的速度确认消息。