将消息发布到数据流中的PubSub主题

Question

在数据流中发布消息/子主题的推荐方法是什么？我曾与客户端API合作，但认为这不是在数据流中处理此问题的最佳方法。

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

Answer 1

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

Pipeline p = Pipeline.create();
// do some transforms
p.apply("publish message", PubsubIO.write().to("pubsub/topic"));

参考：pubsubio