根据我读到的DataFlow，Pub / Sub数据源仅允许消息体在管道中使用 . 我们有一个用例，我们希望检查消息的属性以做出某些决定 . 目前有没有办法实现这一目标？如果需要，我愿意扩展Pub / Sub I / O以包含它 .
目前，无法通过 PubsubIO 连接器访问邮件的邮件属性，但这样做显然很有用 . 这是在Apache Beam（孵化）中跟踪的问题BEAM-404 .
PubsubIO
我建议按照这个问题跟上新的发展 .
1 回答
目前，无法通过
PubsubIO连接器访问邮件的邮件属性，但这样做显然很有用 . 这是在Apache Beam（孵化）中跟踪的问题BEAM-404 .我建议按照这个问题跟上新的发展 .