Compartir a través de


Filtrado e ingesta en Azure Data Explorer mediante el editor sin código de Stream Analytics

En este artículo se describe cómo puede usar el editor sin código para crear fácilmente un trabajo de Stream Analytics. Lee continuamente información de Event Hubs, filtra los datos entrantes y, a continuación, escribe los resultados continuamente en Azure Data Explorer.

Prerrequisitos

  • Los recursos de Azure Event Hubs y Azure Data Explorer deben ser accesibles públicamente y no pueden estar detrás de un firewall ni protegidos en una instancia de Azure Virtual Network.
  • Los datos de Event Hubs deben serializarse en formato JSON, CSV o Avro.

Desarrollo de un trabajo de Stream Analytics para filtrar e ingerir datos en tiempo real

  1. En Azure Portal, busque y seleccione la instancia de Azure Event Hubs.

  2. Seleccione Características>Procesar datos y, a continuación, seleccione Iniciar en la tarjeta Filtrar y almacenar en Azure Data Explorer.

    Captura de pantalla que muestra el filtro y la ingesta a la tarjeta ADLS Gen2 donde se selecciona Inicio.

  3. Escriba un nombre para el trabajo de Stream Analytics y seleccione Crear.

    Captura de pantalla que muestra dónde ingresar un nombre de trabajo.

  4. Especifique el tipo de serialización de los datos en la ventana de Event Hubs y el Método de autenticación que usará 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 y tenga flujos de datos que fluyen a su instancia de Event Hubs, verá inmediatamente dos cosas:

    • Campos que están presentes en los datos de entrada. Puede elegir Agregar campo o seleccionar el símbolo de puntos suspensivos junto a un campo para quitar, cambiar el nombre o cambiar su tipo.
      Captura de pantalla que muestra la lista de campos de Event Hubs donde puede quitar, cambiar el nombre o cambiar el tipo de campo.
    • Ejemplo dinámico de datos entrantes en la tabla de Vista previa de los datos en la vista de diagrama. Se actualiza automáticamente de manera periódica. Puede seleccionar Pause streaming preview (Pausar vista previa de streaming) para ver una vista estática de los datos de entrada de ejemplo.
      Captura de pantalla que muestra datos de ejemplo en Vista previa de datos.
  6. Seleccione el icono Filtro para agregar los datos. En el área Filtro, seleccione un campo para filtrar los datos entrantes con una condición.

    Captura de pantalla que muestra la configuración del operador filter.

  7. Seleccione el icono Administrar. En el panel de configuración Administrar campos, elija los campos que desea generar en el centro de eventos. Si desea agregar todos los campos, seleccione Agregar todos los campos.

    Captura de pantalla que muestra la configuración del operador manage field.

  8. Seleccione el icono Azure Data Explorer. En el panel de configuración, rellene los parámetros necesarios y conéctese.

    Nota

    La tabla debe existir en la base de datos seleccionada y el esquema de tabla debe coincidir exactamente con el número de campos y sus tipos que genera la vista previa de datos.

    Captura de pantalla que muestra la configuración de salida de Kusto.

  9. Opcionalmente, seleccione Obtener vista previa estática o Actualizar vista previa estática para ver la vista previa de los datos que se ingerirán en el centro de eventos.
    Captura de pantalla que muestra la opción Obtener vista previa estática o Actualizar vista previa estática.

  10. Seleccione Guardar y, a continuación, seleccione Iniciar para iniciar el trabajo de Stream Analytics.
    Captura de pantalla que muestra las opciones de Guardar e Iniciar.

  11. Para iniciar el trabajo, especifique:

    • El número de unidades de streaming (SU) con las que se ejecutan los trabajos. Las SU representan la cantidad de procesos y memoria asignadas al trabajo. Se recomienda empezar con tres y, a continuación, ajustar la cantidad según sea necesario.
    • Control de errores de datos de salida: permite especificar el comportamiento que desea cuando se produce un error en la salida de un trabajo en el destino debido a errores de datos. De manera predeterminada, el trabajo reintenta hasta que la operación de escritura se realiza correctamente. También puede optar por quitar estos eventos de salida.
      Captura de pantalla que muestra las opciones de Iniciar trabajo de Stream Analytics, donde puede cambiar el tiempo de salida, establecer el número de unidades de streaming y seleccionar las opciones de control de errores de los datos de salida.
  12. 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 siguiente.

    Captura de pantalla que muestra los datos de las métricas del trabajo después de iniciarse.

    También puede ver el trabajo en la sección Procesar datos de la pestaña Trabajos de Stream Analytics. Seleccione Abrir métricas para supervisarlo, detenerlo o reiniciarlo, según sea necesario.

    Captura de pantalla de la pestaña Trabajos de Stream Analytics en la que se ve el estado de los trabajos en ejecución.

Pasos siguientes

Obtenga más información sobre Azure Stream Analytics y cómo supervisar el trabajo que ha creado.