Desarrolla trabajos de Stream Analytics Edge utilizando herramientas de Visual Studio

En este artículo, aprenderá a usar las herramientas de Stream Analytics para Visual Studio para crear, depurar y generar trabajos de Stream Analytics Edge. Después de crear y probar el trabajo, vas al portal de Azure para desplegarlo en tus dispositivos.

Requisitos previos para desarrollar trabajos en Edge

Necesitas los siguientes requisitos previos para completar los pasos de este artículo:

  1. Instala Visual Studio 2019, Visual Studio 2015 o Visual Studio 2013 Actualización 4. Las herramientas de Stream Analytics soportan las ediciones Enterprise (Ultimate/Premium), Professional y Community, pero no la edición Express.

  2. Siga las instrucciones de instalación para instalar las herramientas de Stream Analytics para Visual Studio.

Crear un proyecto Stream Analytics Edge

Crea el proyecto Edge que contiene la definición de tu puesto.

  1. En Visual Studio, selecciona Archivo>Nuevo>Proyecto. Ve a la lista de Plantillas de la izquierda y, después, expande Azure Stream Analytics>Stream Analytics Edge>Azure Stream Analytics Edge Application. Introduce un nombre, ubicación y nombre de solución para tu proyecto, y luego selecciona OK.

    Captura de pantalla del cuadro de diálogo de New Project para crear una aplicación de Azure Stream Analytics Edge en Visual Studio.

  2. Después de que Visual Studio cree el proyecto, ve a Explorador de soluciones para ver la jerarquía de carpetas.

    Captura de pantalla del Explorador de soluciones mostrando la jerarquía de carpetas de un proyecto Stream Analytics Edge en Visual Studio.

Elige la suscripción correcta

Conecta Visual Studio a la suscripción de Azure donde quieres crear el trabajo.

  1. En el menú Vista de Visual Studio, selecciona Explorador de servidores.

  2. Selecciona y mantén pulsado (o haz clic derecho) en Azure, selecciona Conectarse a la suscripción de Microsoft Azure y luego inicia sesión con tu cuenta de Azure.

Definición de entradas

Configura la entrada del Edge Hub desde la que el trabajo lee los eventos de streaming.

  1. Desde el Explorador de soluciones, expande el nodo Entradas. Ves una entrada llamada EdgeInput.json. Ábrelo para ver sus ajustes.

  2. Establecer el tipo de fuente en flujo de datos. Luego se establece la fuente en edge hub, el formato de serialización de eventos en Json y la codificación en UTF8. Opcionalmente, cambia el nombre del alias de entrada, pero déjalo tal cual para este ejemplo. Si renombras el alias de entrada, usa el nombre que especifiques al definir la consulta. Seleccione Guardar para guardar la configuración. Captura de pantalla de la configuración de la entrada del Edge Hub de Stream Analytics en Visual Studio.

Definición de salidas

Configura la salida de Edge Hub en la que el trabajo escribe los resultados.

  1. Desde el Explorador de soluciones, expande el nodo Outputs. Ves una salida llamada EdgeOutput.json. Ábrelo para ver sus ajustes.

  2. Configura Sink en Edge Hub, Event Serialization Format en Json, Encoding en UTF8 y Format en Array. Opcionalmente, renombra el alias de salida, pero déjalo tal cual en este ejemplo. Si renombras el alias de salida, usa el nombre que especifiques al definir la consulta. Seleccione Guardar para guardar la configuración. Captura de pantalla de la configuración de salida de Stream Analytics Edge Hub en Visual Studio.

Revisar operaciones no soportadas

Los trabajos de Stream Analytics desplegados en los entornos Stream Analytics IoT Edge soportan la mayoría de la referencia del lenguaje de consulta de Stream Analytics. Sin embargo, las siguientes operaciones no están soportadas para los trabajos de Stream Analytics Edge:

  1. PARTICIÓN POR
  2. MARCA TEMPORAL POR SUPERPOSICIÓN
  3. UDF de JavaScript
  4. Agregados definidos por el usuario (UDA)
  5. GetMetadataPropertyValue
  6. Utilizando más de 14 agregados en un solo paso

Cuando creas un trabajo de Stream Analytics Edge en el portal, el compilador te avisa automáticamente si no estás usando un operador compatible.

Definir la consulta de transformación

Desde Visual Studio, define la siguiente consulta de transformación en el editor de consultas (el script.asaql archivo).

SELECT * INTO EdgeOutput
FROM EdgeInput

Prueba el trabajo localmente

Para probar la consulta localmente, sube los datos de muestra. Para obtener datos de muestra, descarga los datos de registro del repositorio de GitHub y guárdalos en tu ordenador local.

  1. Para cargar datos de ejemplo, selecciona y mantén presionado (o haz clic con el botón derecho) el archivo EdgeInput.json y, a continuación, selecciona Añadir entrada local.

  2. En la ventana emergente, navega por los datos de muestra de tu ruta local y selecciona Guardar.

    Captura de pantalla de la configuración local de entrada para subir datos de muestra en Visual Studio.

  3. Visual Studio añade automáticamente un archivo llamado local_EdgeInput.json a tu carpeta de entradas.

  4. Puedes ejecutarlo localmente o enviarlo a Azure. Para probar la consulta, selecciona Ejecutar localmente.

    Captura de pantalla de las opciones de ejecución de trabajos de Stream Analytics que muestran Ejecutar localmente en Visual Studio.

  5. La ventana del símbolo muestra el estado del trabajo. Cuando el trabajo se ejecuta correctamente, crea una carpeta que se muestra como 2018-02-23-11-31-42 en la ruta Visual Studio 2015\Projects\MyASAEdgejob\MyASAEdgejob\ASALocalRun\2018-02-23-11-31-42de tu carpeta del proyecto. Ve a la ruta de la carpeta para ver los resultados en la carpeta local.

    También puedes iniciar sesión en el portal de Azure y verificar que el trabajo está creado.

    Captura de pantalla de la carpeta de resultados del trabajo de Stream Analytics que muestra la salida de la ejecución local en Visual Studio.

Enviar el trabajo a Azure

Después de probar la consulta, publica el trabajo en tu suscripción de Azure.

  1. Antes de enviar el trabajo a Azure, conéctate a tu suscripción de Azure. Abre Server Explorer, selecciona y mantén pulsado (o haz clic derecho) en Azure, selecciona Conectarse a la suscripción a Microsoft Azure y luego inicia sesión en tu suscripción de Azure.

  2. Para enviar el trabajo a Azure, ve al editor de consultas y selecciona Enviar a Azure.

  3. Se abre una ventana emergente. Elige actualizar un trabajo existente en Stream Analytics Edge o crear uno nuevo. Cuando actualizas un trabajo existente, reemplaza toda la configuración del trabajo. En este escenario, publicas un nuevo trabajo. Selecciona Crear un nuevo trabajo en Azure Stream Analytics, introduce un nombre para tu trabajo como MyASAEdgeJob, elige la suscripción, el grupo de recursos y la ubicación requeridas, y luego selecciona Enviar.

    Captura de pantalla del cuadro de diálogo para enviar un trabajo de Stream Analytics Edge a Azure desde Visual Studio.

    Ahora tienes un trabajo en Stream Analytics Edge. Para aprender cómo desplegarlo en tus dispositivos, consulta Ejecutar trabajos en IoT Edge.

Gestiona el trabajo

Gestiona el estado del trabajo y el diagrama del trabajo desde Server Explorer.

  1. Desde Stream Analytics en Server Explorer, amplía la suscripción y el grupo de recursos donde desplegaste el trabajo Stream Analytics Edge. Verás MyASAEdgejob con el estado Creado. Expande el nodo de trabajo y, a continuación, ábrelo para ver el trabajo.

    Captura de pantalla del Explorador de Servidores mostrando opciones de gestión de trabajos para un trabajo en Stream Analytics Edge.

  2. En la ventana de la vista de trabajo, puedes actualizar el trabajo, eliminarlo y abrirlo en el portal de Azure.

    Captura de pantalla de la ventana de la vista de trabajos mostrando el diagrama de trabajo y otras opciones en Visual Studio.

Contenido relacionado

  • Last updated on