goodbyegangster https://blog.hatena.ne.jp/goodbyegangster/ goodbyegangsterのブログ https://goodbyegangster.hatenablog.com/ Google Cloud Dataflow Apache Beam バッチ処理は前回試したので、Streaming の処理を作成してみます。Cloud Pub/Sub からデータを Subscribe して、Cloud Storage 上に Object を作成してみます。 参考です。 Dataflow を使用して Pub/Sub からメッセージをストリーミングする 上記チュートリアルで利用される beam のコード 8. Windowing - Apache Beam Programming Guide 環境 Ubuntu 20.04.4 LTS (WSL2) Python 3.9.13 Apache Beam SDK for Python 2.41.0 事… 190 <iframe src="https://hatenablog-parts.com/embed?url=https%3A%2F%2Fgoodbyegangster.hatenablog.com%2Fentry%2F2022%2F10%2F20%2F081137" title="Dataflow(Streaming) に入門する - goodbyegangsterのブログ" class="embed-card embed-blogcard" scrolling="no" frameborder="0" style="display: block; width: 100%; height: 190px; max-width: 500px; margin: 10px 0px;"></iframe> Hatena Blog https://hatena.blog 2022-10-20 08:11:37 rich https://goodbyegangster.hatenablog.com/entry/2022/10/20/081137 1.0 100%