Contoh ini menunjukkan cara membuat pipeline streaming Apache Beam yang membaca pesan dari Pub/Sub Lite, mengelompokkan pesan menggunakan fungsi periode berukuran tetap, dan menulisnya ke Cloud Storage.
Mempelajari lebih lanjut
Untuk dokumentasi mendetail yang menyertakan contoh kode ini, lihat artikel berikut:
Contoh kode
Java
Untuk mengautentikasi ke Pub/Sub Lite, siapkan Kredensial Default Aplikasi. Untuk mengetahui informasi selengkapnya, baca Menyiapkan autentikasi untuk lingkungan pengembangan lokal.
Langkah selanjutnya
Untuk menelusuri dan memfilter contoh kode untuk produk Google Cloud lainnya, lihat Google Cloud browser contoh.