有没有办法从本地计算机读取csv文件并使用google数据流将其写入大查询或存储?如果存在,应该使用什么运行程序?
所有谷歌数据流示例要么从云端读取,要么写入云存储或大查询。
我使用DirectPipelineRunner从本地计算机读取和写入本地计算机。
DirectPipelineRunner应该可以做到这一点;您可以使用TextIO从本地输入文件中读取并使用BigQueryIO写入BigQuery。