我有以下情况:
您能否让我知道实现此目标的最佳选择是什么?
管道A可以使用TextIO将列名列表写入临时文件或暂存位置文件中,然后由管道执行器读取以定义管道B的架构。如果这种方法看起来不错,请告诉我是否存在数据流实用程序,用于从临时位置或暂存位置或是否应使用GCS API读取文件。
google-cloud-dataflow
google-cloud-dataflow ×1