Microsoft Fabric: ingesta de fila

Use Microsoft Fabric: ingest row para transmitir una fila a una tabla de Eventhouse (KQL) desde un paso de un journey, a través de la API de ingesta de Fabric. A diferencia de los otros puntos de Integraciones que toman su propio token, este se autentica a través de una aplicación de Entra ID conectada una vez para toda la cuenta. No hay un campo de token en el punto en sí.

Usos típicos:

• Alimentar una tabla de informes: insertar una fila por cada paso del journey alcanzado, para un panel de control o una consulta programada posterior.
• Registrar eventos a medida que ocurren: transmitir datos brutos del journey a Eventhouse en lugar de esperar a un pipeline por lotes.
• Unir con datos existentes: insertar un valor de dispositivo o de Tag que sus tablas de Fabric puedan unir con sus propios conjuntos de datos.

Antes de empezar

Conecte una aplicación de Entra ID en Ajustes > Integraciones de terceros > Microsoft Azure:

1. Registre una aplicación en su directorio de Entra ID y cree un secreto de cliente para ella.
2. En ID de directorio (inquilino), introduzca su inquilino, por ejemplo contoso.onmicrosoft.com.
3. En ID de aplicación (cliente), introduzca el ID de cliente del registro de la aplicación.
4. En Secreto de cliente, pegue el secreto. Se almacena como solo escritura: Pushwoosh no lo volverá a mostrar, así que pegue uno nuevo para reemplazarlo.
5. Haga clic en Conectar Azure.

Después de conectar Azure, instale la integración para que el punto aparezca en el constructor de journeys.

Precaución

Un secreto de cliente tiene su propia fecha de caducidad, establecida cuando lo creó en Entra ID. El día que caduca, el punto empieza a fallar y el Panel de Control solo muestra un estado genérico de «reconectar la integración», sin que nada apunte específicamente al secreto. Ponga un recordatorio en la fecha de caducidad del secreto para rotarlo antes de que eso ocurra, no después.

También es necesario que haya tres cosas en su sitio en el lado de Eventhouse, o la solicitud fallará:

• La tabla de destino necesita un mapeo de ingesta JSON; la ingesta por streaming de JSON no funciona sin uno.
• El registro de la aplicación necesita el rol de ingestor en el Eventhouse. No hay un botón para esto en la interfaz de usuario de Fabric; otórguelo ejecutando esto en la ventana de consulta del Eventhouse:

  .add database ['<database name>'] ingestors ('aadapp=<Application (client) ID>;<Directory (tenant) ID>')

• La base de datos KQL necesita tener habilitada su política de ingesta por streaming. Ejecute esto en la misma ventana de consulta:

  .alter database ['<database name>'] policy streamingingestion enable

Mantenga los ['...'] alrededor del nombre de la base de datos en estos comandos si contiene un guion; un nombre con guion sin comillas no se analizará correctamente.

Configurar el punto

1. Arrastre Microsoft Fabric: ingest row desde la sección Integraciones del panel izquierdo al lienzo.
2. Haga doble clic en el punto e introduzca un Nombre del paso.
3. En Host del URI de consulta, introduzca el host de su Eventhouse desde su URI de consulta, en la página de Resumen del sistema del Eventhouse. No incluya https://, por ejemplo trd-abc123.z9.kusto.fabric.microsoft.com.

4. En Base de datos KQL, introduzca el nombre de la base de datos de destino.

5. En Tabla, introduzca el nombre de la tabla de destino.

6. En Mapeo de ingesta, introduzca el nombre del mapeo JSON creado en esa tabla.

7. En Columnas, añada una fila por cada columna de Eventhouse en la que escribir. Introduzca el nombre de la columna y el valor. Los nombres no deben estar vacíos y deben ser únicos. Un valor puede ser texto fijo o una macro de viajero como {{tag:Name}}, las mismas macros que en el cuerpo de un Webhook. O haga clic en Insertar valor dinámico para elegir un atributo que un paso anterior de este journey haya producido, por ejemplo, una respuesta de un LLM o un valor de Webhook mapeado.

Ejemplo

Con Tabla establecida en Events, establecer Columnas en device_id con el ID de dispositivo del viajero ({{device:hwid}}) escribe una fila en la columna device_id de esa tabla.

8. Haga clic en Guardar.

Respuesta

El viajero continúa hacia el paso que conecte a continuación en el lienzo.

Atributos después de que se ejecute el paso

Este punto no mapea ningún dato de respuesta de vuelta al journey.

Fallos y respuestas inesperadas

Abra el Registro de llamadas en el panel del punto y compruebe la respuesta:

• 401 o 403: las credenciales de la aplicación de Entra ID conectada o su rol de ingestor son incorrectos o faltan.
• 520 con StreamingIngestionException: Failed to initialize cursor tracker...: la política de ingesta por streaming de la base de datos KQL no está habilitada. La propia bandera del error permanent: false se interpreta como «reintentar más tarde», pero reintentarlo no soluciona esto. Ejecute .alter database ['<database name>'] policy streamingingestion enable en la ventana de consulta del Eventhouse (consulte Antes de empezar).

Una solicitud fallida elimina al viajero del journey. Consulte Errores y solicitudes fallidas.

Escenario de ejemplo: Transmitir la actividad del journey a un panel de control de Fabric

Un equipo quiere un panel de control en vivo de cada paso alcanzado en un journey activo, sin esperar a una exportación por lotes.

1. Añada Microsoft Fabric: ingest row justo después del paso que desea rastrear. Establezca Base de datos KQL en am-test, Tabla en Events y Mapeo de ingesta en EventsJsonMapping. En Columnas, establezca device_id en {{device:hwid}}.
2. Haga clic en Guardar.

Una vez que esto se ejecute, cada viajero que llegue a este paso aparecerá en la tabla de Eventhouse en segundos, listo para el panel de control.