Prueba de consultas de Stream Analytics localmente en una entrada de streaming en vivo con Visual Studio Code

  • Artículo

Probar la consulta de Stream Analytics localmente con la entrada de streaming en vivo es un paso fundamental para garantizar la precisión y eficacia de la lógica de consulta. Con la extensión de Azure Stream Analytics (ASA) para Visual Studio Code (VS Code), tiene las herramientas necesarias para realizar estas pruebas sin problemas. Este artículo le guía por los pasos necesarios para configurar el entorno, configurar la entrada del streaming en vivo y ejecutar la consulta localmente para realizar pruebas exhaustivas.

Prerrequisitos

Definición de una entrada de streaming en vivo

  1. Haga clic con el botón derecho en la carpeta Entradas del proyecto de Stream Analytics y selecciones ASA: Agregar entrada. Captura de pantalla de agregar una entrada a través del menú desplegable de la extensión de VSCode.O presione Ctrl+Mayús+P para abrir la paleta de comandos y seleccione ASA: Agregar entrada. A continuación, elija el script de consulta para procesar el flujo de entrada. Captura de pantalla de agregar una entrada mediante la paleta de comandos de la extensión de VSCode.

  2. Elija un tipo de origen de entrada en directo de la lista desplegable, Seleccione entre las suscripciones de Azure y escriba un nombre para el origen de entrada. Captura de pantalla de la extensión de VSCode que muestra una serie de pasos para la configuración de la entrada de Event Hubs.

  3. Verá un nuevo archivo JSON creado en la carpeta Entrada. Abra el archivo y Seleccione entre las suscripciones para ayudarle a configurar la entrada de Event Hubs. Captura de pantalla de la extensión de VSCode que muestra la entrada de archivos JSON.

  4. Seleccione Vista previa de los datos para validar si la entrada en directo está configurada correctamente. Captura de pantalla de la vista previa de los datos de entrada en directo de la extensión de VSCode.

Ejecución local de la consulta

Abra el archivo de consulta, seleccione Ejecutar localmente o el botón Reproducir de la barra de menús para abrir una ventana de Opción de ejecución local para configurar el modo de ejecución local.

Captura de pantalla de la selección “Ejecutar localmente” en el editor de consultas de la extensión de VSCode.

Elija Usar entrada en directo y salida local para ejecutar el trabajo localmente frente al flujo de entrada en directo y generar los resultados de salida en una carpeta local. A continuación, seleccione Ejecutar para empezar a ejecutar el trabajo localmente.

Captura de pantalla de la selección del modo de reproducción para la ejecución local de la extensión de VSCode.

Puede ver que se abre una ventana de Prueba local y se actualiza cada 3 segundos. Los resultados de salida se almacenan como formato JSON en la carpeta LocalRunOutputs.

Captura de pantalla de la extensión de VSCode que muestra la ventana de prueba local.

Especificación de las particiones de entrada para pruebas locales

Para evitar la ingesta de todos los datos desde Event Hubs, puede especificar particiones concretas para Event Hubs durante las pruebas locales.

  1. Seleccione Ejecutar localmente para abrir la ventana de opción de ejecución local.
  2. En la sección Seleccionar las particiones de entrada, elija Personalizado.
  3. Escriba los números de partición específicos de los que desea ingerir datos para las pruebas locales.

Captura de pantalla de la extensión de VSCode que especifica las particiones de Event Hub.

Al especificar las particiones, puede centrarse en probar la lógica de consulta sin preocuparse por un gran volumen de datos. Esta característica permite pruebas más eficaces y dirigidas del trabajo de Stream Analytics.

Envío del trabajo a Azure

Una vez completada la prueba de la consulta localmente, puede enviar el proyecto de Stream Analytics a Azure y empezar a ejecutar el trabajo en la nube.

  1. Seleccione la opción Enviar a Azure o seleccione el botón Cargar en el archivo de consulta.
  2. En la ventana opciones de envío, puede actualizar un trabajo existente en Azure o crear un nuevo trabajo para la carga.
  3. Proporcione los detalles necesarios, incluida la suscripción, el grupo de recursos y la región para la implementación.

Captura de pantalla del envío de un trabajo a Azure en la extensión VSCode.

Una vez completado el proceso de envío, puede ver el trabajo en la nube en una nueva ventana. Desde allí, puede supervisar su rendimiento y administrar sus configuraciones según sea necesario. También puede abrir el trabajo en el explorador haciendo clic en el vínculo proporcionado en el panel SALIDA.

Captura de pantalla de la extensión de VSCode que muestra la vista en la nube del trabajo.

Pasos siguientes