Creación de secuencias de eventos predeterminadas y derivadas

En este artículo se muestra cómo crear flujos de eventos predeterminados y derivados de Microsoft Fabric. Un flujo de datos es un flujo dinámico y continuo de datos que ofrece una gama de funcionalidades para la acción y el análisis inmediatos. Con un flujo de datos, puede configurar alertas en tiempo real, introducir en diferentes tipos de almacenes de datos y habilitar un modelo de publicación o suscripción al que varios clientes pueden suscribirse.

La integración de la función hub en tiempo real dentro de los flujos de eventos de Fabric mejora aún más estas capacidades. Esta integración le permite crear y administrar varios flujos de datos con diferentes operaciones de procesamiento, que luego se pueden mostrar en el centro en tiempo real.

Conceptos

  • Eventstream es un elemento dentro del área de trabajo de Fabric que permite ingerir, transformar y enrutar flujos de datos a varios destinos de Fabric.

  • Una secuencia es un flujo continuo y sin enlazar de eventos de datos. Cuando los eventos de datos fluyen hacia los flujos de eventos de Fabric, se forma un flujo dentro de los flujos de eventos de Fabric para representar los eventos de datos. Hay dos tipos de flujos en los flujos de eventos de Fabric:

    • Secuencia predeterminada. Cada elemento de secuencia de eventos de Fabric incluye una secuencia predeterminada que se genera automáticamente una vez que se agrega un origen de streaming a la secuencia de eventos. Representa los eventos sin procesar procedentes del origen de streaming. Puede transformar y enrutar la secuencia predeterminada a varios destinos de Fabric. Puede ver el flujo predeterminado desde el centro de tiempo real.

    • La secuencia derivada es un tipo especializado de destino en secuencias de eventos de Fabric que se crean después de la adición de una serie de operaciones de secuencia, como Filtrar o Administrar campos. La secuencia derivada representa la secuencia predeterminada transformada después del procesamiento del flujo. También puede enrutar los datos de streaming en el flujo derivado a varios destinos en Fabric. Una vez creado, está listo para su posterior consumo o análisis por parte de otros usuarios de la organización a través del centro en tiempo real.

Creación de una secuencia predeterminada

Una vez creada una secuencia de eventos, puede agregar un origen a la secuencia de eventos y la secuencia predeterminada se genera automáticamente. En el ejemplo siguiente se muestra que el flujo predeterminado es-5-stream se genera automáticamente al agregar un origen de datos de ejemplo de bicicletas al elemento Flujos de eventos de Fabric.

Captura de pantalla de una secuencia predeterminada generada automáticamente.

Creación de una secuencia derivada

  1. Para crear una nueva secuencia derivada, agregue una operación como Filtro a la secuencia de eventos. A continuación, seleccione la opción Stream.

    Captura de pantalla de la creación de una secuencia derivada.

  2. Asigne un nombre a la nueva secuencia y seleccione Publicar para confirmar los cambios.

    Captura de pantalla de la publicación de un flujo derivado.

    Una vez completado el proceso, puede acceder tanto a sus flujos predeterminados como a los derivados en Real-Time hub para seguir trabajando con ellos, por ejemplo, obtener una vista previa del flujo o agregar destinos a los que enviarlo.

    Captura de pantalla del acceso a un flujo derivado en Real-Time hub.

Pausar y reanudar transmisiones derivadas

Ahora puedes pausar y reanudar el tráfico de tus secuencias derivadas. Esto proporciona mayor flexibilidad y control sobre el flujo de datos sin eliminar ni volver a configurar la topología de eventstream.

Cuando se pausa una secuencia derivada, Eventstream detiene temporalmente el envío de datos a su destino y conserva todas las configuraciones de flujo. Puede reanudar el tráfico en cualquier momento para continuar procesando eventos sin problemas.

Use esta característica para:

  • Detenga temporalmente el flujo de datos para el mantenimiento o la solución de problemas.
  • Reduzca los costos de ingesta o procesamiento durante las pruebas o períodos de baja actividad.