Tous les exemples de code Pub/Sub Lite

Cette page a été traduite par l'API Cloud Translation.

Supprimer la réservation Lite

Supprimer une réservation Pub/Sub Lite

Pub/Sub Lite
Java
Go
Python

Créer un sujet Lite

Créez un sujet Lite à partition unique et configurez sa période de conservation, le stockage par partition et le facteur de scaling du débit de publication.

Pub/Sub Lite
Python
Java
Go

Supprimer un abonnement Lite

Supprimez un abonnement Lite.

Pub/Sub Lite
Go
Python
Java

Recevoir des messages dans Apache Kafka

Recevoir des messages depuis un abonnement Pub/Sub Lite à l'aide d'un shim pour l'API Kafka Consumer

Pub/Sub Lite
Java

Publier avec des attributs personnalisés

Publiez des messages avec des attributs personnalisés.

Pub/Sub Lite
Python
Java
Go

Modifier la réservation Lite

Modifier une réservation Pub/Sub Lite

Pub/Sub Lite
Python
Go
Java

Publiez des messages avec une clé de tri. Les clés de tri sont hachées pour être mappées à une partition. Les messages de la même clé de tri sont publiés dans la même partition. Si la partition est remplie, les messages les plus anciens sont écrasés.

Pub/Sub Lite
Java
Go
Python

Mettre à jour un abonnement Lite

Mettre à jour le mode de distribution d'un abonnement Lite.

Pub/Sub Lite
Go
Java
Python

Publier

Publiez des messages dans un sujet Lite à partition unique et résolvez les futures publications de manière asynchrone.

Pub/Sub Lite
Python
Java
Go

Publier avec des paramètres de traitement par lots

Publier des messages avec des paramètres de traitement par lots.

Pub/Sub Lite
Go
Python
Java

Rechercher un emplacement dans un abonnement Pub/Sub Lite

Recherchez un emplacement dans un abonnement Pub/Sub Lite pour commencer à recevoir des messages de cet emplacement.

Pub/Sub Lite
Go
Python
Java

Répertorier les abonnements Lite dans un projet

Répertorier les abonnements Lite dans un projet.

Pub/Sub Lite
Java
Go
Python

Répertorier les sujets Lite

Répertoriez les sujets Lite dans un projet.

Pub/Sub Lite
Go
Java
Python

Écrire dans Pub/Sub Lite à partir de Spark (diffusion en continu)

Écrire des messages dans un sujet Pub/Sub Lite à partir d'un cluster Spark en mode streaming.

Pub/Sub Lite
Python

Mettre à jour un sujet Lite

Mettez à jour la durée de conservation, le facteur de scaling (capacité de débit) et le nombre d'octets de partition (capacité de stockage) d'un sujet Lite.

Pub/Sub Lite
Python
Java
Go

Répertorier les abonnements Lite dans un sujet

Répertoriez les abonnements Lite dans un sujet Lite.

Pub/Sub Lite
Java
Python
Go

Diffuser des Pub/Sub Lite vers Cloud Storage à l'aide de Dataflow.

Cet exemple montre comment créer un pipeline de streaming Apache Beam qui lit les messages de Pub/Sub Lite, les regroupe à l'aide d'une fonction de fenêtrage de taille fixe et les écrit dans Cloud Storage.