Semua contoh kode Pub/Sub Lite
Halaman ini berisi contoh kode untuk Pub/Sub Lite. Untuk menelusuri dan memfilter contoh kode untuk produk Google Cloud lainnya, lihat browser contohGoogle Cloud .
Publikasi
Memublikasikan pesan ke topik Lite satu partisi dan me-resolve future publikasi secara asinkron.
- PubSub Lite
- Google Cloud
- Java
- Python
- Go
Memublikasikan dengan atribut khusus
Memublikasikan pesan dengan atribut khusus.
- PubSub Lite
- Google Cloud
- Python
- Java
- Go
Memublikasikan pesan dari Apache Kafka
Memublikasikan pesan ke topik Pub/Sub Lite menggunakan shim untuk Kafka Producer API
- PubSub Lite
- Google Cloud
- Java
Memublikasikan dengan kunci pengurutan
Memublikasikan pesan dengan kunci pengurutan. Kunci pengurutan di-hash untuk dipetakan ke partisi. Pesan dengan kunci pengurutan yang sama dipublikasikan ke partisi yang sama. Jika partisi terisi penuh, pesan terlama akan ditimpa.
- PubSub Lite
- Google Cloud
- Go
- Java
- Python
Menerima pesan di Apache Kafka
Menerima pesan dari langganan Pub/Sub Lite menggunakan shim untuk Kafka Consumer API
- PubSub Lite
- Google Cloud
- Java
Melakukan streaming Pub/Sub Lite ke Cloud Storage menggunakan Dataflow
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.
- Google Cloud
- PubSub Lite
- Java
Membuat topik Lite
Buat topik Lite satu partisi dan konfigurasikan periode retensi, penyimpanan per partisi, dan faktor penskalaan throughput publikasi.
- Google Cloud
- PubSub Lite
- Go
- Python
- Java
Buat langganan Lite
Buat langganan Lite dengan mode pengiriman yang dipilih.
- Google Cloud
- PubSub Lite
- Go
- Java
- Python
Mencantumkan langganan Lite dalam project
Mencantumkan langganan Lite dalam project.
- Google Cloud
- PubSub Lite
- Python
- Go
- Java
Mencari lokasi di langganan Pub/Sub Lite
Mencari lokasi di langganan Pub/Sub Lite untuk mulai menerima pesan dari lokasi tersebut.
- PubSub Lite
- Google Cloud
- Python
- Go
- Java
Mencantumkan langganan Lite dalam topik
Mencantumkan langganan Lite dalam topik Lite.
- PubSub Lite
- Google Cloud
- Go
- Java
- Python
Mendapatkan langganan Lite
Mencetak nama, jalur topik, dan konfigurasi pengiriman langganan Lite.
- PubSub Lite
- Google Cloud
- Python
- Go
- Java
Membaca dari Pub/Sub Lite dari Spark (streaming)
Membaca pesan dari langganan Pub/Sub Lite dari cluster Spark dalam mode streaming.
- Google Cloud
- PubSub Lite
- Python
Mendapatkan topik Lite
Mencetak nama, konfigurasi retensi, dan konfigurasi partisi topik Lite.
- Google Cloud
- PubSub Lite
- Go
- Python
- Java
Menulis ke Pub/Sub Lite dari Spark (streaming)
Menulis pesan ke topik Pub/Sub Lite dari cluster Spark dalam mode streaming.
- PubSub Lite
- Google Cloud
- Python
Membuat langganan Lite yang menulis pesan ke topik Pub/Sub
Membuat langganan Lite yang menulis pesan ke topik Pub/Sub
- PubSub Lite
- Google Cloud
- Go
- Python
- Java
Memublikasikan dengan setelan batch
Memublikasikan pesan dengan setelan batch.
- Google Cloud
- PubSub Lite
- Java
- Go
- Python
Berlangganan
Gunakan pelanggan multi-partisi dan yang dikontrol alur (kumpulan pelanggan) untuk berlangganan topik multi-partisi dan memproses pesan secara asinkron dalam callback.
- PubSub Lite
- Google Cloud
- Python
- Java
- Go
Memperbarui langganan Lite
Memperbarui mode pengiriman langganan Lite.
- PubSub Lite
- Google Cloud
- Java
- Python
- Go
Memperbarui topik Lite
Perbarui periode retensi, faktor penskalaan (kapasitas throughput), dan byte per partisi (kapasitas penyimpanan) dari topik Lite.
- Google Cloud
- PubSub Lite
- Python
- Java
- Go