Todas os exemplos de código do Pub/Sub Lite
Esta página contém exemplos de código do Pub/Sub Lite. Para pesquisar e filtrar exemplos de código de outros produtos Google Cloud , consulte a pesquisa de exemplos de código doGoogle Cloud .
Acessar assinatura do Lite
Imprimir o nome, o caminho do tópico e a configuração de entrega de uma assinatura do Lite.
- Pub/Sub Lite
- Java
- Go
- Python
Criar tópico do Lite
Crie um tópico do Lite de partição única e configure o período de armazenamento, o armazenamento por partição e o fator de escalonamento de capacidade de publicação.
- Pub/Sub Lite
- Go
- Java
- Python
Receber mensagens no Apache Kafka
Receber mensagens de uma assinatura do Pub/Sub Lite usando um shim para a API Consumer Kafka
- Pub/Sub Lite
- Java
Publicar mensagens do Apache Kafka
Publicar mensagens em um tópico do Pub/Sub Lite usando um shim para a API Kafka Producer
- Pub/Sub Lite
- Java
Acessar tópico do Lite
Imprimir nome, configuração de retenção e configuração de partição de um tópico do Lite.
- Pub/Sub Lite
- Python
- Java
- Go
Atualizar assinatura do Lite
Atualizar o modo de transferência de uma assinatura do Lite.
- Pub/Sub Lite
- Java
- Python
- Go
Criar assinatura do Lite
Crie uma assinatura do Lite com um modo de entrega escolhido.
- Pub/Sub Lite
- Java
- Python
- Go
Ler pelo Pub/Sub Lite do Spark (streaming)
Leia mensagens de uma assinatura do Pub/Sub Lite de um cluster do Spark no modo de streaming.
- Pub/Sub Lite
- Python
Listar assinaturas do Lite no projeto
Listar assinaturas do Lite em um projeto.
- Pub/Sub Lite
- Python
- Go
- Java
Publicar
Publicar mensagens em um tópico do Lite de partição única e resolver as futuras publicações assincronamente.
- Pub/Sub Lite
- Python
- Java
- Go
Procurar um local em uma assinatura do Pub/Sub Lite
Busque um local em uma assinatura do Pub/Sub Lite para começar a receber mensagens dele.
- Pub/Sub Lite
- Java
- Python
- Go
Criar uma assinatura Lite que grava mensagens em um tópico do Pub/Sub
Criar uma assinatura Lite que grava mensagens em um tópico do Pub/Sub
- Pub/Sub Lite
- Go
- Python
- Java
Publicar com atributos personalizados
Publique mensagens com atributos personalizados.
- Pub/Sub Lite
- Go
- Java
- Python
Publicar com configurações de lote
Publicar mensagens com configurações de lote.
- Pub/Sub Lite
- Go
- Java
- Python
Atualizar tópico do Lite
Atualizar o período de armazenamento, o fator de escalonamento (capacidade de produção) e bytes por partição (capacidade de armazenamento) de um tópico do Lite.
- Pub/Sub Lite
- Go
- Python
- Java
Faça streaming do Pub/Sub Lite para o Cloud Storage usando o Dataflow.
Neste exemplo, você vê como criar um pipeline de streaming do Apache Beam que lê mensagens do Pub/Sub Lite, agrupa as mensagens usando uma função de janela de tamanho fixo e as grava no Cloud Storage.
- Pub/Sub Lite
- Java
Inscreva-se
Use um assinante com várias partições e controle de fluxo (uma coleção de assinantes) para assinar um tópico em várias partições e processar as mensagens de forma assíncrona em callbacks.
- Pub/Sub Lite
- Java
- Go
- Python
Publicar com chaves de ordem
Publicar mensagens com uma chave de ordem. As chaves de ordem têm hash para mapear para uma partição. As mensagens da mesma chave de ordem são publicadas na mesma partição. Se a partição estiver preenchida, as mensagens mais antigas serão sobrescritas.
- Pub/Sub Lite
- Java
- Python
- Go
Gravar no Pub/Sub Lite do Spark (streaming)
Grave mensagens em um tópico do Pub/Sub Lite de um cluster Spark no modo de streaming.
- Pub/Sub Lite
- Python
Listar assinaturas do Lite no tópico
Listar assinaturas do Lite em um tópico do Lite.
- Pub/Sub Lite
- Go
- Python
- Java