Transmite eventos a tu propio broker
Publica registros de flujos en Pub/Sub, Kafka, SNS, SQS o AMQP: tus topics, tu infraestructura, semántica de exactamente-una-vez.
Para equipos que quieren eventos, no exportaciones: la acción de cola de mensajes publica cada registro de flujo en un broker de tu propiedad: Google Pub/Sub, Kafka, AWS SNS, SQS o cualquier broker AMQP. La autenticación es seria: para Pub/Sub, concede a una cuenta de servicio publicadora dedicada de privilegios mínimos acceso a tu topic (sin secreto almacenado) o aporta una clave acotada que se cifra en reposo. La entrega va envuelta en idempotencia, admite claves de ordenación por registro y hay una prueba de conectividad antes de que dependas de ella.
Disparadores de workflow
Entrante: usa webhooks o programaciones
No hay disparador de consumo de broker: las vías entrantes son webhooks HTTP, lecturas por sondeo y carpetas activas. Esta página trata de sacar eventos de forma fiable.
Acciones de workflow
Publicar en Pub/Sub, Kafka, SNS, SQS, AMQP
Una acción, cinco adaptadores de broker: elige la conexión y los registros fluyen como mensajes.
Ordenación e idempotencia
Claves de ordenación por registro donde el broker las admite; la idempotencia envuelta en el envío hace que las reentregas repitan el resultado en caché en lugar de publicar dos veces.
Prueba de conectividad
Un endpoint de prueba de entrega verifica la conexión antes del tráfico de producción.
Cómo fluyen los datos
Solo saliente, por diseño: la alternativa duradera a los callbacks por webhook. Las respuestas de encuestas, los registros enriquecidos y las salidas de flujos aterrizan en tus topics; tus consumidores hacen el resto.
Conexión: Conexiones por broker creadas una vez, con el topic de destino fijado en la creación. Pub/Sub admite concesión IAM (sin secreto almacenado) o una clave de cuenta de servicio acotada y cifrada; los demás brokers usan sus credenciales nativas.
Ejemplo práctico: Respuestas a tu plataforma de datos, en modo evento
Crea una conexión de Pub/Sub: concede a la cuenta de servicio publicadora roles/pubsub.publisher en tu topic; no se intercambian claves.
Disparador: cada respuesta de encuesta ejecuta un flujo de enriquecimiento.
Acción: el registro enriquecido se publica en tu topic con el id del encuestado como clave de ordenación.
Tu pipeline de Dataflow/consumidor lo recoge como cualquier otra fuente de eventos.
Configuración
1.
Crea una conexión de broker (concesión IAM de Pub/Sub o clave acotada; credenciales nativas para Kafka/SNS/SQS/AMQP).
2.
Ejecuta la prueba de conectividad.
3.
Añade la acción de cola de mensajes a cualquier flujo y selecciona la conexión.
Preguntas frecuentes
¿Qué brokers se admiten?
Google Pub/Sub, Kafka, AWS SNS, AWS SQS y brokers compatibles con AMQP: una acción, cinco adaptadores.
¿Cómo se autentica Pub/Sub?
Dos modos: concede a nuestra cuenta de servicio publicadora dedicada de privilegios mínimos roles/pubsub.publisher en tu topic (no se almacena ningún secreto), o aporta una clave de cuenta de servicio acotada, cifrada en reposo.
¿Puede SurveyAnalytica consumir también de mi broker?
Hoy no: la entrada es mediante webhooks, lecturas programadas por sondeo y carpetas activas. El streaming es saliente.