Cloud DataflowでGCS→BQのパイプラインをPythonで試してみる