【发布时间】:2019-08-20 09:45:29
【问题描述】:
我只想在一个时间范围内接收消息,因为之前和之后的消息都损坏了数据。
我知道我可以寻找到起始位置,这样问题就解决了,如何配置另一端(在特定时间停止)。
非常感谢任何答案或建议。 设置间隔后,如果有帮助,我计划从 python 代码中读取消息。
【问题讨论】:
标签: python google-cloud-platform publish-subscribe google-cloud-pubsub
我只想在一个时间范围内接收消息,因为之前和之后的消息都损坏了数据。
我知道我可以寻找到起始位置,这样问题就解决了,如何配置另一端(在特定时间停止)。
非常感谢任何答案或建议。 设置间隔后,如果有帮助,我计划从 python 代码中读取消息。
【问题讨论】:
标签: python google-cloud-platform publish-subscribe google-cloud-pubsub
没有针对此的集成解决方案。您必须在 Python 中实现一个过滤器来丢弃数据损坏的消息。
但是,您的用例很有趣,在 issue tracker 上提出功能请求可能会在未来帮助您(和其他人)。
【讨论】: