google-cloud-dataflow - 在 Cloud DataFlow 中访问 Cloud Pub/Sub Message 属性

Question

根据我对 DataFlow 的阅读，Pub/Sub 数据源仅提供消息正文以在管道中使用。我们有一个用例，我们想要检查消息的属性以做出某些决定。目前有没有办法实现这一目标？如果需要，我愿意扩展 Pub/Sub I/O 以合并它。

Answer 1

目前，无法通过PubsubIO连接器访问消息的消息属性，但这样做显然很有用。这在 Apache Beam（孵化）中作为问题BEAM-404进行了跟踪。

我建议关注此问题以了解最新动态。