在 Apache Beam 中使用 PubsubIO.writeStrings() 的优势

Question

Apache Beam 提供了

PubsubIO.writeStrings()

方法，该方法返回一个

PTransform

，可用于直接从

PCollection

将消息写入 Pubsub：Example.

使用这个而不是编写一个写消息的自定义

DoFn

（例如，this的DoFn）有什么明显的优势吗？

Answer 1

PubsubIO.writeStrings

是Beam提出的原生

输出连接器

。

A

DoFn

是

Beam

中的常用变换，可以在每个步骤中使用。

如果您没有特定需求，最好将本机 IO 与

Beam

一起使用，不要重新发明轮子并使用他们提供的支持。

如果您必须创建自定义 IO，此 link 可以提供帮助。