Uso de un flujo de datos en una canalización

En este tutorial, creará una canalización para mover OData de un origen de Northwind a un destino de Lakehouse y enviará una notificación por correo electrónico cuando se complete la canalización.

Requisitos previos

Para empezar, debe completar los siguientes requisitos previos:

Creación de un almacén de lago de datos

Para empezar, primero debe crear un lakehouse. Un lakehouse es un lago de datos optimizado para el análisis. En este tutorial, creará un Lakehouse que se utiliza como destino del flujo de datos.

  1. Vaya al área de trabajo habilitada para Fabric.

    Captura de pantalla del área de trabajo con Fabric habilitado resaltada.

  2. Seleccione Lakehouse en el menú Crear.

    Recorte de pantalla del menú Crear con Crear Lakehouse enfatizado.

  3. Escriba un Nombre para lakehouse.

  4. Seleccione Crear.

Ahora ha creado una instancia LakeHouse y ahora puede configurar el flujo de datos.

Crear un flujo de datos

Un flujo de datos es una transformación de datos reutilizable que se puede utilizar en una canalización. En este tutorial, creará un flujo de datos que obtiene datos de un origen de OData y escribe los datos en un destino de lakehouse.

  1. Vaya al área de trabajo habilitada para Fabric.

    Captura de pantalla del área de trabajo habilitado para Fabric.

  2. Seleccione Flujo de datos Gen2 en el menú crear.

    Captura de pantalla de la selección de Dataflow Gen2 en el nuevo menú.

  3. Importar los datos desde el origen OData.

    1. Seleccione Obtener datos y, a continuación, seleccione Más.

      Captura de pantalla del menú Obtener datos con «Más» resaltado.

    2. En Elegir origen de datos, busque ODatay, a continuación, seleccione el conector de OData.

      Captura de pantalla del menú Obtener datos con OData resaltado.

    3. Escribir el URL del origen OData. Para este tutorial, usar Servicio de ejemplo OData.

    4. Seleccione Siguiente.

    5. Seleccionar la Entidad que desea ingerir. En este tutorial, usar la entidad Orders.

      Captura de pantalla de la versión preliminar de OData.

    6. Seleccione Crear.

Ahora que ha ingerido los datos del origen de OData, puede configurar el destino de lakehouse.

Para ingerir los datos en el destino Lakehouse:

  1. Seleccionar Agregar destino de datos.

  2. Seleccionar Lakehouse.

    Captura de pantalla del menú Agregar destino de salida con lakehouse enfatizado.

  3. Configure la conexión que desea usar para conectarse a lakehouse. La configuración predeterminada está bien.

  4. Seleccione Siguiente.

  5. Navegue hasta el área de trabajo donde ha creado lakeHouse.

  6. Seleccione el lakehouse que ha creado en los pasos anteriores.

    Captura de pantalla del lakehouse seleccionado.

  7. Confirmar el nombre de la tabla.

  8. Seleccione Siguiente.

  9. Confirmar el método de actualización y seleccionar Guardar configuración.

    Captura de pantalla de los métodos de actualización, con reemplazo seleccionado.

  10. Publicar el flujo de datos.

    Importante

    Cuando se crea el primer Dataflow Gen2 en un área de trabajo, se aprovisionan los elementos Lakehouse y Warehouse, junto con su punto de conexión de análisis de SQL y sus modelos semánticos relacionados. Todos los flujos de datos del área de trabajo comparten estos elementos, que son necesarios para el funcionamiento de Flujo de datos Gen2, no deben eliminarse y los usuarios no deben utilizarlos directamente. Los elementos son un detalle de implementación de Dataflow Gen2. Los elementos no están visibles en el área de trabajo, pero podrían estar accesibles en otras experiencias, como el Notebook, el punto de conexión de SQL, Lakehouse y Warehouse. Puede reconocer los elementos por su prefijo en el nombre. El prefijo de los elementos es "DataflowsStaging".

Ahora que ha ingerido los datos en el destino de lakehouse, puede configurar la canalización.

Crear una canalización

Una canalización es un flujo de trabajo que se puede usar para automatizar el procesamiento de datos. En este tutorial, creará una canalización que ejecuta el flujo de datos Gen2 que creó en el procedimiento anterior.

  1. Vuelva a la página de información general del área de trabajo y seleccione Canalizaciones en el menú Crear.

    Captura de pantalla que muestra la selección de tubería.

  2. Proporcione un nombre para la canalización.

  3. Seleccione la actividad Flujo de datos.

    Captura de pantalla de la actividad de flujo de datos enfatizada.

  4. Seleccione el Flujo de datos que ha creado en el procedimiento anterior en la lista desplegable Flujo de datos en Configuración.

    Captura de pantalla de la lista desplegable de flujo de datos.

  5. Agregue una actividad de Office 365 Outlook.

    Captura de pantalla que resalta cómo seleccionar una actividad de Office 365 Outlook.

  6. Configure la actividad de Office 365 Outlook para enviar una notificación por correo electrónico.

    1. Autentifíquese con su cuenta de Office 365.

    2. Seleccione la Dirección de Email a la que desea enviar la notificación.

    3. Escriba un Asunto para el correo electrónico.

    4. Introduzca un cuerpo del mensaje para el correo electrónico.

      Captura de pantalla que muestra la configuración de actividad de Office 365 Outlook.

Ejecución y programación de la canalización

En esta sección, se ejecuta y programa el flujo de trabajo.

  1. Vaya a su área de trabajo.

  2. Abra el menú desplegable de la canalización que creó en el procedimiento anterior y, a continuación, seleccione Programar.

    Captura de pantalla del menú de canalización con la programación enfatizada.

  3. En Ejecución programada, seleccione Activado.

    Captura de pantalla de una ejecución programada configurada como Activado.

  4. Proporcione el cronograma que desea usar para ejecutar la canalización.

    1. Repita, por ejemplo, cada Día o cada Minuto.
    2. Al seleccionar Diariamente, también puede seleccionar la hora.
    3. Comience en una fecha específica.
    4. Finalice Activar una Fecha determinada.
    5. Seleccione la Zona horaria.

  5. Seleccione Aplicar para aplicar los cambios.

Ahora ha creado una canalización que se ejecuta según una programación, actualiza los datos en lakehouse y le envía una notificación por correo electrónico. Para comprobar el estado de la canalización, vaya al Centro de supervisión. También puede comprobar el estado de la canalización; para ello, vaya a Canalización y seleccione la pestaña Historial de ejecución en el menú desplegable.

Contenido relacionado

  • Last updated on