Diffusez vos événements vers votre propre broker
Publiez les enregistrements de workflow vers Pub/Sub, Kafka, SNS, SQS ou AMQP — vos topics, votre infrastructure, une sémantique exactly-once.
Pour les équipes qui veulent des événements, pas des exports : l'action message-queue publie chaque enregistrement de workflow vers un broker qui vous appartient — Google Pub/Sub, Kafka, AWS SNS, SQS ou tout broker AMQP. L'authentification est sérieuse : pour Pub/Sub, accordez à un compte de service éditeur dédié à faibles privilèges l'accès à votre topic (aucun secret stocké) ou fournissez une clé restreinte chiffrée au repos. La livraison est encapsulée en idempotence, gère des clés d'ordonnancement par enregistrement, et une sonde de connectivité valide la connexion avant que vous ne vous y fiiez.
Déclencheurs de workflow
Entrant : utilisez webhooks ou planifications
Il n'y a pas de déclencheur de consommation de broker — les voies entrantes sont les webhooks HTTP, les lectures par interrogation et les dossiers surveillés. Cette page traite de la sortie fiable des événements.
Actions de workflow
Publier vers Pub/Sub, Kafka, SNS, SQS, AMQP
Une action, cinq adaptateurs de broker — choisissez la connexion, les enregistrements partent en messages.
Ordonnancement et idempotence
Clés d'ordonnancement par enregistrement quand le broker les gère ; l'idempotence encapsulée fait que les relivraisons rejouent le résultat en cache au lieu de publier en double.
Test de connectivité
Un endpoint de test de livraison vérifie la connexion avant le trafic de production.
Comment circulent les données
Sortant uniquement, par conception — l'alternative durable aux rappels webhook. Réponses d'enquête, enregistrements enrichis et sorties de workflow atterrissent sur vos topics ; vos consommateurs font le reste.
Connexion: Connexions par broker créées une fois, avec le topic de destination fixé à la création. Pub/Sub accepte l'octroi IAM (aucun secret stocké) ou une clé de compte de service restreinte et chiffrée ; les autres brokers utilisent leurs identifiants natifs.
Exemple concret: Les réponses dans votre plateforme de données, façon événements
Créez une connexion Pub/Sub : accordez au compte de service éditeur roles/pubsub.publisher sur votre topic — aucune clé échangée.
Déclencheur : chaque réponse d'enquête exécute un workflow d'enrichissement.
Action : l'enregistrement enrichi est publié sur votre topic avec l'identifiant du répondant comme clé d'ordonnancement.
Votre pipeline Dataflow/consommateur le récupère comme n'importe quelle autre source d'événements.
Mise en place
1.
Créez une connexion broker (octroi IAM Pub/Sub ou clé restreinte ; identifiants natifs pour Kafka/SNS/SQS/AMQP).
2.
Lancez le test de connectivité.
3.
Ajoutez l'action message-queue à un workflow et sélectionnez la connexion.
Questions fréquentes
Quels brokers sont pris en charge ?
Google Pub/Sub, Kafka, AWS SNS, AWS SQS et les brokers compatibles AMQP — une action, cinq adaptateurs.
Comment Pub/Sub est-il authentifié ?
Deux modes : accordez à notre compte de service éditeur dédié à faibles privilèges roles/pubsub.publisher sur votre topic (aucun secret jamais stocké), ou fournissez une clé de compte de service restreinte, chiffrée au repos.
SurveyAnalytica peut-il aussi consommer depuis mon broker ?
Pas aujourd'hui — l'entrant passe par les webhooks, les lectures planifiées par interrogation et les dossiers surveillés. Le streaming est sortant.