当没有消息消耗时停止流式传输管道

问题描述 投票:1回答:1

我有一个流数据流管道作业,它从给定的pub-sub主题中读取消息。我知道捆绑包提交后会有自动确认。如何让管道在没有消息消耗的地方停止?

编辑 - 我有一个场景,我需要排除发送到主题的不正确的消息。因此,这将是一次性工作。我的应用程序每天仅向该主题发送1MM消息(固定时间)。

google-cloud-platform google-cloud-dataflow google-cloud-pubsub
1个回答
1
投票

你为什么要停止流媒体管道,担心在管道什么也不做的时候被收费?如果您担心这一点,那么您根本不应该担心,因为您只需要为您使用的资源付费,例如CPU小时,内存,磁盘存储等。请参阅价格详情here

由于您的源是无限的(例如PubSub),因此您无法确定将来不会有更多的传入数据。

© www.soinside.com 2019 - 2024. All rights reserved.