我正在创建一个气流管道,其中我使用BigQueryOperator查询我的BigQuery表,并使用BigQueryToCloudStorageOperator将结果表导出为GCS。
我需要将csv移动到mysql数据库,在那里它应该作为表存储在mysql数据库中。
我能得到任何关于如何实现这一点的建议或想法吗?谢谢!
发布于 2021-02-09 11:49:19
由于您的用例是在BigQuery中查询数据并将数据存储在MySql数据库中,因此可以使用BigQueryToMySqlOperator。
从BigQuery表中获取数据(或者获取选定列的数据),并将该数据插入到MySQL表中。
https://stackoverflow.com/questions/66051097
复制相似问题