キャンペーンのためのCloud Dataflow によるニアリアルタイムなイベント処理