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