Trasmetti gli eventi al tuo broker
Pubblica i record dei workflow su Pub/Sub, Kafka, SNS, SQS o AMQP — i tuoi topic, la tua infrastruttura, semantica exactly-once.
Per i team che vogliono eventi, non export: l'azione message-queue pubblica ogni record del workflow su un broker di tua proprietà — Google Pub/Sub, Kafka, AWS SNS, SQS o qualsiasi broker AMQP. L'autenticazione è seria: per Pub/Sub, concedi a un service account publisher dedicato a privilegi minimi l'accesso al tuo topic (nessun segreto memorizzato) oppure fornisci una chiave con scope, cifrata a riposo. La consegna è avvolta in idempotenza, supporta ordering key per record e c'è una prova di connettività prima di farci affidamento.
Trigger di workflow
In entrata: usa webhook o pianificazioni
Non esiste un trigger di consumo dal broker — i percorsi in entrata sono webhook HTTP, letture in polling e hot folder. Questa pagina riguarda il far uscire gli eventi in modo affidabile.
Azioni di workflow
Pubblica su Pub/Sub, Kafka, SNS, SQS, AMQP
Un'azione, cinque adapter di broker — scegli la connessione e i record fluiscono come messaggi.
Ordinamento e idempotenza
Ordering key per record dove il broker le supporta; l'idempotenza a livello di dispatch fa sì che le riconsegne ripropongano il risultato in cache invece di pubblicare due volte.
Test di connettività
Un endpoint di prova di consegna verifica la connessione prima del traffico di produzione.
Come fluiscono i dati
Solo in uscita, per scelta — l'alternativa durevole alle callback webhook. Risposte ai sondaggi, record arricchiti e output dei workflow atterrano sui tuoi topic; il resto lo fanno i tuoi consumer.
Connessione: Connessioni per broker create una sola volta, con il topic di destinazione fissato alla creazione. Pub/Sub supporta la concessione IAM (nessun segreto memorizzato) o una chiave di service account con scope cifrata; gli altri broker usano le loro credenziali native.
Esempio pratico: Le risposte nella tua data platform, in stile evento
Crea una connessione Pub/Sub: concedi al service account publisher roles/pubsub.publisher sul tuo topic — nessuna chiave scambiata.
Trigger: ogni risposta al sondaggio esegue un workflow di arricchimento.
Azione: il record arricchito viene pubblicato sul tuo topic con l'id del rispondente come ordering key.
La tua pipeline Dataflow/consumer lo raccoglie come qualsiasi altra sorgente di eventi.
Configurazione
1.
Crea una connessione al broker (concessione IAM per Pub/Sub o chiave con scope; credenziali native per Kafka/SNS/SQS/AMQP).
2.
Esegui il test di connettività.
3.
Aggiungi l'azione message-queue a qualsiasi workflow e seleziona la connessione.
Domande frequenti
Quali broker sono supportati?
Google Pub/Sub, Kafka, AWS SNS, AWS SQS e broker compatibili AMQP — un'azione, cinque adapter.
Come si autentica Pub/Sub?
Due modalità: concedi al nostro service account publisher dedicato a privilegi minimi roles/pubsub.publisher sul tuo topic (nessun segreto viene mai memorizzato), oppure fornisci una chiave di service account con scope, cifrata a riposo.
SurveyAnalytica può anche consumare dal mio broker?
Oggi no — l'ingresso avviene via webhook, letture pianificate in polling e hot folder. Lo streaming è in uscita.