GCPのCloud Pub/SubをトリガーとしたData Fusionのリアルタイムパイプラインを作成しました。Cloud Pub/Subにデータを投入後、Data Fusionパイプラインを経由し、BigQueryのテーブルに格納されるフローの構築となります。リアルタイムパイプラインではSourceにPub/Sub、TransformにWrangler、SinkにBigQueryをしました。