在流式数据流管道中,如何动态更改写入云存储的存储桶或数据前缀?
例如,我想将数据存储到GCS上的文本或avro文件中,但前缀包括处理时间。
更新:该问题无效,因为您根本没有可以在写入Google Cloud Storage的流式数据流中使用的接收器。
Google Cloud Dataflow目前不允许流模式下的GCS接收器。