Google Cloud Pub/Sub

Google Cloud Pub/Sub est le service de messaging asynchrone managé de Google Cloud. Conçu globalement (replication multi-régions automatique) et serverless (pas de provisioning de capacity), il combine les caractéristiques d'un message broker (durabilité, retry, DLQ) et d'un event streaming (high-throughput, replay).

Concepts : (1) Topic — point de publication ; (2) Subscription — endpoint de consommation, plusieurs subscriptions par topic (chaque sub reçoit tous les messages indépendamment) ; (3) Pull subscription (consumer polls) vs Push subscription (Pub/Sub posts to HTTPS endpoint, Cloud Run, Cloud Functions) ; (4) Schema (Avro, Protobuf) optionnel avec validation ; (5) Dead Letter Topic ; (6) Retry policy (exponential backoff).

Features : (1) Ordering keys — ordering garanti par clé d'ordering au sein d'une région (depuis 2020) ; (2) Exactly-once delivery (depuis 2022) — élimination des duplicatas côté consumer avec checkpointing ; (3) Message retention configurable jusqu'à 7 jours (31 jours via subscription retain-acked-messages) avec seek/replay ; (4) Filtering côté Pub/Sub (les subs filtrent les messages selon attributs avant livraison) ; (5) Snapshot/Seek — créer un snapshot d'une subscription pour retour à un point dans le temps ; (6) Pub/Sub Lite — version low-cost avec capacity provisioning zone-based, idéal très haut volume budget-sensitive.

Pub/Sub vs Kafka/Kinesis/Event Hubs : (1) Pub/Sub plus simple ops (truly serverless, pas de partitions/shards à gérer) ; (2) latence légèrement supérieure (~100ms vs ~10ms Kinesis/Kafka) ; (3) auto-scaling global instantané (pas de planning capacity) ; (4) ordering limité (per-key, intra-region) vs Kafka per-partition cross-broker ; (5) intégrations GCP natives nombreuses.

Intégrations : Cloud Functions trigger, Cloud Run push subscription, Dataflow streaming pipelines (Apache Beam), BigQuery direct ingestion (Pub/Sub → BQ subscription depuis 2022, no Dataflow needed), Cloud Storage delivery, Cloud Logging sink, Firebase, IoT Core.

Use cases : event-driven microservices, IoT ingestion, real-time analytics pipelines (clickstream, ad-tech), application-to-application async, multi-region fanout (un publish global → consumers world-wide), CDC streaming. Pricing : ~$40 par TB ingéré (region-dependent), facturé par GB throughput + messages count selon mode. Pub/Sub Lite ~10x moins cher pour très haut throughput. Compétences clés pour Professional Cloud Architect et Data Engineer GCP.