Tutti gli esempi di codice Pub/Sub Lite
Questa pagina contiene esempi di codice per Pub/Sub Lite. Per cercare e filtrare i sample di codice per altri Google Cloud prodotti, consulta il Google Cloud browser di sample.
Crea sottoscrizione Lite
Crea una sottoscrizione Lite con una modalità di invio scelta.
- Pub/Sub Lite
- Go
- Python
- Java
Recupero di un argomento Lite
Stampa il nome, la configurazione di conservazione e la configurazione della partizione di un argomento Lite.
- Pub/Sub Lite
- Go
- Python
- Java
Recupero di una sottoscrizione Lite
Stampa il nome, il percorso dell'argomento e la configurazione di importazione di una sottoscrizione Lite.
- Pub/Sub Lite
- Java
- Go
- Python
Ricezione di messaggi in Apache Kafka
Ricevere messaggi da una sottoscrizione Pub/Sub Lite utilizzando uno shim per l'API Kafka Consumer
- Pub/Sub Lite
- Java
Pubblicazione di messaggi da Apache Kafka
Pubblicare messaggi in un argomento Pub/Sub Lite utilizzando uno shim per l'API Kafka Producer
- Pub/Sub Lite
- Java
Elenco di sottoscrizioni Lite nel progetto
Elenca le sottoscrizioni Lite in un progetto.
- Pub/Sub Lite
- Python
- Java
- Go
Creare una sottoscrizione Lite che scriva messaggi in un argomento Pub/Sub
Creare una sottoscrizione Lite che scriva messaggi in un argomento Pub/Sub
- Pub/Sub Lite
- Go
- Java
- Python
Crea argomento Lite
Crea un argomento Lite a partizione singola e configura il periodo di conservazione, lo spazio di archiviazione per partizione e il fattore di scala della velocità effettiva di pubblicazione.
- Pub/Sub Lite
- Java
- Python
- Go
Pubblicazione con attributi personalizzati
Pubblicare messaggi con attributi personalizzati.
- Pub/Sub Lite
- Go
- Python
- Java
Aggiornamento di una sottoscrizione Lite
Aggiornare la modalità di consegna di una sottoscrizione Lite.
- Pub/Sub Lite
- Java
- Go
- Python
Aggiornamento di un argomento Lite
Aggiorna il periodo di conservazione, il fattore di scalabilità (capacità di throughput) e i byte per partizione (capacità di archiviazione) di un argomento Lite.
- Pub/Sub Lite
- Python
- Java
- Go
Scrittura in Pub/Sub Lite da Spark (flusso di dati)
Scrivi messaggi in un argomento Pub/Sub Lite da un cluster Spark in modalità di streaming.
- Pub/Sub Lite
- Python
Pubblica
Pubblica messaggi in un argomento Lite a partizione singola e risolvi i futures di pubblicazione in modo asincrono.
- Pub/Sub Lite
- Go
- Java
- Python
Esecuzione del flusso di Pub/Sub Lite in Cloud Storage tramite Dataflow
Questo esempio mostra come creare una pipeline di streaming Apache Beam che legga i messaggi da Pub/Sub Lite, raggruppi i messaggi utilizzando una funzione di finestra di dimensioni fisse e li scriva in Cloud Storage.
- Pub/Sub Lite
- Java
Iscriviti
Utilizza un sottoscrittore con più partizioni e controllo del flusso (una raccolta di sottoscrittori) per iscriverti a un argomento con più partizioni ed elaborare i messaggi in modo asincrono nei callback.
- Pub/Sub Lite
- Java
- Python
- Go
Lettura da Pub/Sub Lite da Spark (flusso di dati)
Leggi i messaggi da una sottoscrizione Pub/Sub Lite da un cluster Spark in modalità di streaming.
- Pub/Sub Lite
- Python
Pubblicazione con chiavi di ordinamento
Pubblica i messaggi con una chiave di ordinamento. Le chiavi di ordinamento vengono sottoposte ad hashing per essere associate a una partizione. I messaggi con la stessa chiave di ordinamento vengono pubblicati nella stessa partizione. Se la partizione è piena, i messaggi meno recenti vengono sovrascritti.
- Pub/Sub Lite
- Java
- Python
- Go
Elenco di sottoscrizioni Lite nell'argomento
Elenca le sottoscrizioni Lite in un argomento Lite.
- Pub/Sub Lite
- Java
- Python
- Go
Pubblicazione con impostazioni batch
Pubblica i messaggi con le impostazioni batch.
- Pub/Sub Lite
- Java
- Python
- Go
Ricerca di una località in una sottoscrizione Pub/Sub Lite
Cerca una località in una sottoscrizione Pub/Sub Lite per iniziare a ricevere messaggi da quella località.
- Pub/Sub Lite
- Go
- Java
- Python