从有界数据流管道到 pub/sub 的确定性发布顺序

Deteministic publishing order from a bounded dataflow pipeline to pub/sub

有没有办法以确定的顺序将来自有界数据流管道(批处理模式)的消息发布到 PubSubIO.Write 中,以便它们至少按大致顺序按此顺序传送。例如。使用时间戳或 natural/sorted 排序。

无法对写入 PubSubIO.Write 的数据进行确定性排序。即使消息按顺序发布到 Pub/Sub,您的订阅者也不会按顺序接收它们,因为 Cloud Pub/Sub 没有顺序保证。通常,最好尽可能避免使用 Pub/Sub 对顺序的依赖,尽管有一些技术可以处理它。我推荐阅读新出版的 Message Ordering doc.