Procesamiento de datos de un centro de eventos con Azure Stream Analytics

El servicio Azure Stream Analytics permite ingerir, procesar y analizar fácilmente los datos de streaming procedentes de Azure Event Hubs, lo que proporciona valiosa información para emprender acciones en tiempo real. Esta integración le permite crear rápidamente una canalización de análisis de la ruta de acceso activa. Puede usar Azure Portal para visualizar los datos de entrada y escribir una consulta de Stream Analytics. Cuando la consulta esté lista, podrá transferirla a producción con solo unos pocos clics.

Ventajas principales

Estas son las principales ventajas de la integración de Azure Event Hubs y Azure Stream Analytics:

  • Vista previa de datos: puede obtener una vista previa de los datos de entrada de un centro de eventos en Azure Portal.
  • Comprobación de la consulta: prepare una consulta de transformación y pruébela directamente en Azure Portal. Si necesita información sobre la sintaxis del lenguaje de consulta, consulte la documentación sobre el lenguaje de consulta de Stream Analytics.
  • Implementación de la consulta en producción: puede implementar la consulta en producción creando e iniciando un trabajo de Azure Stream Analytics.

Flujo integral

Importante

Si no es miembro de roles de propietario o colaborador en el nivel de suscripción de Azure, debe ser miembro del rol evaluador de consultas de Stream Analytics en el nivel de suscripción de Azure para completar correctamente los pasos de esta sección. Este rol le permite realizar consultas de prueba sin crear primero un trabajo de Stream Analytics. Para obtener instrucciones sobre cómo asignar un rol a un usuario, consulte Asignación de roles de AD a usuarios.

  1. Inicie sesión en Azure Portal.

  2. Vaya al espacio de nombres de Event Hubs y acceda al centro de eventos que contiene los datos de entrada.

  3. Seleccione Procesar datos en la página del centro de eventos.

    Process data tile

  4. En el icono Enable real-time insights from events (Extraer información en tiempo real de los eventos), seleccione Explorar.

    Select Stream Analytics

  5. Aparecerá una página de consulta con los valores ya establecidos en los campos siguientes:

    1. El centro de eventos, como entrada de la consulta.

    2. Una consulta SQL de ejemplo con la instrucción SELECT.

    3. Un alias de salida que hace referencia a los resultados de la prueba de consulta.

      Query editor

      Nota:

      Si usa esta característica por primera vez, esta página le pedirá permiso para crear un grupo de consumidores y una directiva del centro de eventos para obtener una vista previa de los datos de entrada.

  6. Seleccione Crear en el panel Vista previa de la entrada, tal como se muestra en la imagen anterior.

  7. Aparecerá inmediatamente una instantánea de los últimos datos de entrada en esta pestaña.

    • El tipo de serialización de los datos se detecta automáticamente (JSON o CSV). Puede cambiarlo manualmente a JSON, CSV o AVRO.

    • Puede obtener una vista previa de los datos de entrada en formato de tabla o en formato sin procesar.

    • Si los datos que aparecen no están actualizados, seleccione Actualizar para ver los eventos más recientes.

      A continuación, se incluye un ejemplo de datos en formato de tabla: Results in the table format

      Este es un ejemplo de los datos con formato sin procesar:

      Results in the raw format

  8. Seleccione Test query (Consulta de prueba) para ver una instantánea de los resultados de prueba de la consulta en la pestaña Test results (Resultados de la prueba). También puede descargar los resultados.

    Test query results

  9. Escriba su propia consulta para transformar los datos. Consulte Stream Analytics Query Language reference (Referencia del lenguaje de consulta de Stream Analytics).///

  10. Cuando haya probado la consulta y desee moverla a producción, seleccione Deploy query (Implementar consulta). Para implementar la consulta, cree un trabajo de Azure Stream Analytics, donde podrá configurar una salida del trabajo e iniciarlo. Para crear un trabajo de Stream Analytics, especifique un nombre para el trabajo y seleccione Create (Crear).

    Create an Azure Stream Analytics job

    Nota:

    Le recomendamos que cree un grupo de consumidores y una directiva para cada nuevo trabajo de Azure Stream Analytics que cree en la página de Event Hubs. Los grupos de consumidores solo permiten cinco lectores simultáneos, por lo que, si se proporciona un grupo de consumidores dedicado para cada trabajo, se evitarán los errores que podrían surgir en caso de que se superara ese límite. Las directivas dedicadas le permiten cambiar la clave o revocar permisos sin afectar a otros recursos.

  11. El trabajo de Stream Analytics se crea en el mismo lugar de la consulta que coincide con la consulta probada; el centro de eventos se utiliza como entrada.

  12. Para completar la canalización, establezca la salida de la consulta y seleccione Start (Iniciar) para iniciar el trabajo.

    Nota:

    Antes de iniciar el trabajo, no olvide reemplazar el alias de salida por el nombre de salida que creó en Azure Stream Analytics.

    Set output and start the job

Restricciones conocidas

Cuando se prueba la consulta, los resultados tardan aproximadamente seis segundos en cargarse. Estamos trabajando para mejorar el rendimiento de las pruebas. Sin embargo, cuando se implementa en producción, la latencia de Azure Stream Analytics es inferior a un segundo.

Unidades de streaming

El valor de Azure Stream Analytics se establece de forma predeterminada en tres unidades de streaming (SU). Para ajustar esta configuración, seleccione Escala en el menú izquierdo de la página Trabajo de Stream Analytics de Azure Portal. Para más información sobre las unidades de streaming, consulte Descripción y ajuste de las unidades de streaming.

Scale streaming units

Pasos siguientes

Para más información sobre de las consultas de Stream Analytics, consulte este artículo sobre el lenguaje de consulta de Stream Analytics