google-cloud-dataflow - 将消息发布到 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