阅读背景:

读取PubsubIO写入DatastoreIO

来源:互联网 

Is it possible to create a pipeline that reads data from Pub/Sub and writes to Datastore? In my code I specify the PubsubIO as the input, and apply windowing to get a bounded PCollection, but it seems that it is not possible to use the DatastoreIO.writeTo with the options.setStreaming as true, while that is required in order to use PubsubIO as input. Is there a way around this? Or is it simply not possible to read from pubsub and write to datastore? Is it possible to create a pipeline that reads




你的当前访问异常,请进行认证后继续阅读剩余内容。

分享到: