Compartir a través de

Captura de datos de Event Hubs en formato de Delta Lake

  • Artículo

En este artículo se explica cómo usar el editor de no código para capturar automáticamente datos de streaming en Event Hubs en una cuenta de Azure Data Lake Storage Gen2 en formato de Delta Lake.

Requisitos previos

  • Los recursos de Azure Event Hubs y Azure Data Lake Storage Gen2 deben tener acceso público y no pueden estar detrás de un firewall o protegidos en una red virtual de Azure.
  • Los datos de Event Hubs deben serializarse en formato JSON, CSV o Avro.

Configuración de un trabajo para capturar datos

Siga estos pasos para configurar un trabajo de Stream Analytics para capturar datos en Azure Data Lake Storage Gen2.

  1. En Azure Portal, vaya al centro de eventos.

  2. Seleccione Características>Procesar datos, y seleccione Iniciar en la tarjeta Capturar datos a ADLS Gen2 en formato de Delta Lake.
    Captura de pantalla que muestra las tarjetas de inicio de datos del procesamiento de Event Hubs.

    Como alternativa, seleccione Características>Capturar. Después, seleccione la opción Delta Lake en "Formato de serialización de eventos de salida"y, luego, seleccione Iniciar configuración de captura de datos. Captura de pantalla que muestra el punto de entrada de la creación de datos de captura.

  3. Escriba un nombre para identificar el trabajo de Stream Analytics. Seleccione Crear.
    Captura de pantalla que muestra la ventana Nuevo trabajo de Stream Analytics donde se especifica el nombre del trabajo.

  4. Especifique el tipo de Serialización de los datos en Event Hubs y el Método de autenticación que usa el trabajo para conectarse a Event Hubs. A continuación, seleccione Conectar. Captura de pantalla que muestra la configuración de conexión de Event Hubs.

  5. Cuando la conexión se establezca correctamente, verá lo siguiente:

    • Campos que están presentes en los datos de entrada. Puede elegir Agregar campo o puede seleccionar el símbolo de los tres puntos junto a un campo para, opcionalmente, eliminar, renombrar o cambiar su nombre.
    • Ejemplo dinámico de datos entrantes en la tabla de Vista previa de los datos en la vista de diagrama. Se actualiza periódicamente. Puede seleccionar Pausar la versión preliminar del streaming para ver una vista estática de la entrada de la muestra.
      Captura de pantalla que muestra datos de ejemplo en Vista previa de datos.

  6. Seleccione el mosaico Azure Data Lake Storage Gen2 para editar la configuración.

  7. En la página de configuración de Azure Data Lake Storage Gen2, siga estos pasos:

    1. Seleccione la suscripción, el nombre de la cuenta de almacenamiento y el contenedor en el menú desplegable.

    2. Una vez seleccionada la suscripción, el método de autenticación y la clave de la cuenta de almacenamiento deberían rellenarse automáticamente.

    3. En el caso de la ruta de acceso de tabla de Delta se usa para especificar la ubicación y el nombre de la tabla de Delta Lake almacenada en Azure Data Lake Storage Gen2. Puede optar por usar uno o varios segmentos de ruta de acceso para definir la ruta de acceso a la tabla Delta y el nombre de la tabla Delta. Para más información, consulte Escritura en tablas de Delta Lake.

    4. Seleccione Conectar.

      Primera captura de pantalla que muestra la ventana Blob donde se edita una configuración de conexión de blob.

  8. Cuando se establezca la conexión, verá los campos que están presentes en los datos de salida.

  9. Seleccione Guardar en la barra de comandos para guardar la configuración.

  10. Seleccione Iniciar en la barra de comandos para iniciar el flujo de streaming y capturar datos. A continuación, en la ventana Iniciar trabajo de Stream Analytics:

    1. Seleccione la hora de inicio de la salida.
    2. Seleccione el número de Unidades de streaming (SU) con las que se ejecuta el trabajo. Las unidades de streaming representan los recursos informáticos que se asignan para ejecutar un trabajo de Stream Analytics. Para más información, consulte Unidades de streaming en Azure Stream Analytics.
      Captura de pantalla que muestra la ventana Inicio del trabajo de Stream Analytics donde se especifica la hora de inicio de salida, las unidades de streaming y el control de errores.

  11. Después de seleccionar Iniciar, el trabajo comienza a ejecutarse en un máximo de dos minutos y las métricas se abrirán en la sección de pestañas como se muestra en la imagen siguiente. Captura de pantalla que muestra el gráfico de métricas.

  12. El nuevo trabajo se puede ver en la pestaña Trabajos de Stream Analytics. Captura de pantalla que muestra el vínculo Abrir métricas seleccionado.

Comprobar salida

Compruebe que los archivos de Parquet con formato de Delta Lake se generan en el contenedor de Azure Data Lake Storage.

Captura de pantalla que muestra los archivos Parquet generados en el contenedor de Azure Data Lake Storage (ADLS).

Pasos siguientes

Ya sabe cómo usar el editor de código de Stream Analytics para crear un trabajo que capture los datos de Event Hubs para Azure Data Lake Storage Gen2 en formato de Delta Lake. A continuación, puede obtener más información sobre Azure Stream Analytics y cómo supervisar el trabajo que ha creado.