从 Dataflow 写入 Google Cloud Storage 时如何更改存储桶或前缀?
How can I change bucket or prefix when writing to Google Cloud Storage from Dataflow?
在流数据流管道中,如何动态更改存储桶或写入云存储的数据前缀?
例如,我想将数据存储到 GCS 上的文本或 avro 文件中,但前缀包含处理时间。
更新: 该问题无效,因为根本没有可用于写入 Google 云存储的流数据流的接收器。
Google Cloud Dataflow 目前不允许流模式下的 GCS 接收器。
在流数据流管道中,如何动态更改存储桶或写入云存储的数据前缀?
例如,我想将数据存储到 GCS 上的文本或 avro 文件中,但前缀包含处理时间。
更新: 该问题无效,因为根本没有可用于写入 Google 云存储的流数据流的接收器。
Google Cloud Dataflow 目前不允许流模式下的 GCS 接收器。