2017-12-18 14 views

答えて

0

残念ながら、これは少なくとも1変換なしではできません。最低限の変換は、CSV(文字列)の1行をPython辞書に変換するか、TableRow(BigQuery APIから)をBigQuerySink経由でBigQueryに書き込むために必要です。

また、bqコマンドラインツールを使用して、CSVをBigQueryにアップロードすることもできます。これははるかに簡単で、cronのようなアプリケーションでスケジュールすることができます。注:このソリューションには、請求の意味が異なります。

bq load --source_format=CSV <destination_table> <data_source_uri> [<table_schema>] 

BQコマンドラインツール参照:https://cloud.google.com/bigquery/bq-command-line-tool

+0

Iが関連付けられた列をマージするデータフローを使用してコードを書かれている –

+0

以下のように、私は名前に関連付けられた列をマージするPythonでデータフローを使用してコードを書かれています名前がどういうものか分かりません。正しい方向に私を導くことができます –

+0

データフローを使用して名前に関連する列をマージし、BigQueryに書き込むコードを書いたことがありますが、どうにかして正しくは得られません。方向 –

関連する問題