すべての Pub/Sub Lite のコードサンプル
このページには、Pub/Sub Lite のコードサンプルが掲載されています。他の Google Cloud プロダクトのコードサンプルを検索およびフィルタするには、Google Cloud サンプル ブラウザをご覧ください。
Pub/Sub トピックにメッセージを書き込む Lite サブスクリプションを作成する
Pub/Sub トピックにメッセージを書き込む Lite サブスクリプションを作成する
- Pub/Sub Lite
- Java
- Go
- Python
Lite トピックを作成
パーティション ストレージごとに、単一パーティション Lite トピックを作成してその保持期間を設定し、スループットのスケーリング ファクタをパブリッシュします。
- Pub/Sub Lite
- Go
- Python
- Java
Apache Kafka からのメッセージのパブリッシュ
Kafka Producer API 用の shim を使用してメッセージを Pub/Sub Lite トピックにパブリッシュする
- Pub/Sub Lite
- Java
順序指定キーを使用したパブリッシュ
順序指定キーを使用してメッセージをパブリッシュします。 順序指定キーは、ハッシュされてパーティションにマッピングされます。同じ順序指定キーのメッセージは、同じパーティションにパブリッシュされます。パーティションがいっぱいになると、最も古いメッセージから上書きされます。
- Pub/Sub Lite
- Go
- Python
- Java
登録
マルチ パーティションのサブスクライバーとフロー制御のサブスクライバー(サブスクライバーのコレクション)を使用して、マルチパーティション トピックにサブスクライブし、コールバックで非同期にメッセージを処理します。
- Pub/Sub Lite
- Python
- Java
- Go
Dataflow を使用した Pub/Sub Lite の Cloud Storage へのストリーミング
このサンプルは、Pub/Sub Lite からメッセージを読み取り、固定サイズのウィンドウ処理機能を使用してメッセージをグループ化し、Cloud Storage に書き込む Apache Beam ストリーミング パイプラインを作成する方法を示しています。
- Pub/Sub Lite
- Java
Lite トピックの更新
Lite トピックの保持期間、スケーリング ファクタ(スループット容量)、パーティションごとのバイト(ストレージ容量)を更新します。
- Pub/Sub Lite
- Go
- Java
- Python
Spark(ストリーミング)から Pub/Sub Lite への書き込み
ストリーミング モードで Spark クラスタからの Pub/Sub Lite トピックにメッセージを書き込む。
- Pub/Sub Lite
- Python
Apache Kafka でメッセージを受信する
Kafka Consumer API 用の shim を使用して Pub/Sub Lite サブスクリプションからメッセージを受信する
- Pub/Sub Lite
- Java
Pub/Sub Lite サブスクリプション内のロケーションへのシーク
Pub/Sub Lite サブスクリプション内のロケーションまでシークして、そのロケーションからメッセージの受信を開始します。
- Pub/Sub Lite
- Java
- Python
- Go
Spark(Streaming)からの Pub/Sub Lite から読み取る
ストリーミング モードで Spark クラスタからの Pub/Sub Lite サブスクリプションからメッセージを読み込みます。
- Pub/Sub Lite
- Python