python - 在某个时间范围内从 google pub/sub 接收消息

Question

我只想在一个时间范围内接收消息，因为之前和之后的消息都损坏了数据。

我知道我可以寻找到起始位置，这样问题就解决了，我该如何配置另一端（在特定时间停止）。

非常感谢任何答案或建议。设置间隔后，如果有帮助，我计划从 python 代码中读取消息。

标签： pythongoogle-cloud-platformpublish-subscribegoogle-cloud-pubsub

Answer 1

没有针对此的集成解决方案。你必须在 Python 中实现一个过滤器来丢弃带有损坏数据的消息。

但是，您的用例很有趣，并且在问题跟踪器上打开功能请求可以在将来帮助您（和其他人）。