将消息发布到 Dataflow 中的 Pubsub 主题

Question

在 Dataflow 中将消息发布到 Pub/Sub 主题的推荐方法是什么。 我使用过客户端 API，但认为这不是在 Dataflow 中处理此问题的最佳方式。

PublishResponse response = client.projects().topics()
                        .publish(fullTopicName, publishRequest)
                        .execute();

Answer 1

从 Dataflow 作业向 PubSub 主题发布消息的最佳方法是使用 PubsubIO 类。示例：

Pipeline p = Pipeline.create();

// do some transforms

p.apply("publish message", PubsubIO.write().to("pubsub/topic"));

参考：PubsubIO