Inicio rápido: crea un trabajo de Stream Analytics en Visual Studio

En este inicio rápido, creas un trabajo de Stream Analytics utilizando las herramientas de Azure Stream Analytics para Visual Studio. El trabajo de ejemplo lee datos en streaming desde un dispositivo hub IoT. Defines un trabajo que calcula la temperatura media cuando el valor supera los 27° y escribe los eventos de salida resultantes en un nuevo archivo en el almacenamiento de blobs.

Prerequisites

Antes de empezar, asegúrate de tener los siguientes requisitos previos.

Nota:

Para obtener la mejor experiencia de desarrollo local, use las herramientas Stream Analytics para Visual Studio Code. Las herramientas de Stream Analytics para Visual Studio 2019 (versión 2.6.3000.0) presentan carencias conocidas en las funciones y no reciben más mejoras. Las herramientas de Visual Studio y Visual Studio Code no admiten trabajos en las regiones Este de China, Norte de China, Centro de Alemania y Norte de Alemania.

Preparación de los datos de entrada

Antes de definir el trabajo de Análisis de Flujos, prepara los datos que luego configures como entrada de trabajo. Para preparar los datos de entrada, complete los siguientes pasos:

  1. Inicie sesión en Azure Portal.

  2. Seleccione Create a resource Internet of ThingsIoT Hub>> IoT Hub).

  3. En el panel IoT Hub , escriba la siguiente información:

    Configuración Valor sugerido Descripción
    Subscription <Su suscripción> Seleccione la suscripción de Azure que quiera usar.
    Grupo de recursos asaquickstart-resourcegroup Seleccione Crear nuevo y escriba un nuevo nombre de grupo de recursos para la cuenta.
    Nombre de IoT Hub MyASAIoTHub Selecciona un nombre para tu hub IoT.
    Región <Selecciona la región más cercana a tus usuarios> Selecciona una ubicación geográfica donde puedas alojar tu hub IoT. Use la ubicación más cercana a los usuarios.
    Nivel Gratuito Para este inicio rápido, seleccione Gratis si todavía está disponible en su suscripción. Si el nivel gratis no está disponible, elija el nivel más bajo disponible. Para más información, consulte Precios de IoT Hub.

    Captura de pantalla que muestra el Asistente para crear IoT Hub en Azure Portal.

  4. Selecciona Revisar + crear. Revisa la información de tu hub IoT y selecciona Crear. Tu hub IoT puede tardar unos minutos en crearse. Supervise el progreso en el panel Notificaciones .

  5. Una vez finalizada la implementación, selecciona Ir a recurso para acceder a la página del hub IoT de tu hub.

  6. En la página IoT Hub , seleccione Dispositivos en Administración de dispositivos en el menú de navegación izquierdo.

  7. En la página Dispositivos , seleccione + Agregar dispositivo en la barra de herramientas.

    Captura de pantalla que muestra la página Dispositivos con Agregar dispositivo seleccionado.

  8. En la página Crear un dispositivo , escriba un nombre para el dispositivo y seleccione Guardar.

    Captura de pantalla que muestra la página Crear un dispositivo.

  9. Después de crear el dispositivo, ábrelo desde la lista de dispositivos IoT . Si aún no ve el dispositivo, actualice la página.

    Captura de pantalla que muestra la lista de dispositivos con el dispositivo que creó.

  10. Copie la cadena de conexión principal y guárdela en un Bloc de notas para usarla más adelante.

Creación de un almacenamiento de blobs

En esta sección, creas una cuenta de Azure Storage y un contenedor de blob para almacenar los eventos de salida de tu trabajo.

  1. En la esquina superior izquierda de Azure Portal, seleccione Crear un recurso>Almacenamiento>Cuenta de almacenamiento.

  2. En el panel Crear cuenta de almacenamiento , escriba un nombre de cuenta de almacenamiento, una ubicación y un grupo de recursos. Elija la misma ubicación y grupo de recursos que el IoT Hub que creaste. A continuación, seleccione Revisar y crear para crear la cuenta.

    Captura de pantalla que muestra la página Crear cuenta de almacenamiento en Azure Portal.

  3. Después de crear tu cuenta de almacenamiento, selecciona la casilla de servicio Blob en el panel de Resumen .

    Captura de pantalla que muestra la página de información general de la cuenta de almacenamiento con Blob service seleccionado.

  4. En la página Blob service , seleccione + Contenedor en la barra de herramientas.

  5. En la página Nuevo contenedor , escriba un nombre para el contenedor, como container1. Deje el nivel de acceso Público como Privado (sin acceso anónimo) y seleccione Crear.

    Captura de pantalla que muestra la página Nuevo contenedor.

Creación de un proyecto de Stream Analytics

Crea un proyecto de Análisis de Flujos en Visual Studio para definir las entradas, salidas y consulta del trabajo.

  1. Inicie Visual Studio.

  2. Seleccione Archivo>Nuevo proyecto.

  3. En la lista de plantillas, selecciona Stream Analytics y luego Azure Stream Analytics Application.

  4. Introduce el nombre del proyecto, la ubicación y el nombre de la solución, y selecciona Crear.

    Captura de pantalla que muestra el cuadro de diálogo Crear un proyecto de Stream Analytics.

  5. Fíjate en los elementos en un proyecto de Azure Stream Analytics.

    Captura de pantalla que muestra la ventana explorador de soluciones para un proyecto de aplicación de Stream Analytics de ejemplo en Visual Studio.

Elección de la suscripción necesaria

Conecta Visual Studio a la suscripción de Azure que contiene los recursos que creaste.

  1. En Visual Studio, en el menú Ver , seleccione 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 la entrada

Configura la entrada de trabajo para que lea datos en streaming del hub IoT que has creado.

  1. En Explorador de soluciones, expande el nodo Entradas y abre Input.json.

  2. Rellene la configuración de entrada de Stream Analytics con los siguientes valores:

    Configuración Valor sugerido Descripción
    Alias de entrada Input Introduzca un nombre para identificar la entrada de la tarea.
    Tipo de origen Flujo de datos Elija el origen de entrada adecuado: Flujo de datos o Datos de referencia.
    Fuente IoT Hub Elija el origen de entrada adecuado.
    Resource Elegir origen de datos de la cuenta actual Elija especificar los datos manualmente o seleccione una cuenta existente.
    Subscription <Su suscripción> Selecciona la suscripción de Azure que tiene el hub IoT que creaste.
    IoT Hub MyASAIoTHub Elige o introduce el nombre de tu hub IoT. Los nombres de los hubs IoT aparecen automáticamente si los creas en la misma suscripción.

  3. Deje otras opciones en valores predeterminados y seleccione Guardar para guardar la configuración.

    Captura de pantalla que muestra la página Configuración de entrada de Stream Analytics.

Definición de la salida

Configura la salida del trabajo para escribir los resultados en tu contenedor de almacenamiento de blobs.

  1. En Explorador de soluciones, expande el nodo Outputs y abre Output.json.

  2. Rellene la configuración de salida de Stream Analytics con los siguientes valores:

    Configuración Valor sugerido Descripción
    Alias de salida Salida Introduce un nombre para identificar los resultados de la tarea.
    Receptor Data Lake Storage Gen 2/Blob Storage Elija el receptor adecuado.
    Resource Proporcionar la configuración del origen de datos manualmente Elija especificar los datos manualmente o seleccione una cuenta existente.
    Subscription <Su suscripción> Seleccione la suscripción de Azure que tiene la cuenta de almacenamiento que ha creado. La cuenta de almacenamiento puede estar en la misma suscripción o en otra. Este ejemplo asume que creaste una cuenta de almacenamiento en la misma suscripción.
    Cuenta de almacenamiento asaquickstartstorage Elija o escriba el nombre de la cuenta de almacenamiento. Los nombres de las cuentas de almacenamiento aparecen automáticamente si los creas en la misma suscripción.
    Contenedor contenedor1 Seleccione el contenedor existente que creó en la cuenta de almacenamiento.
    Patrón de ruta output Introduce el nombre de la ruta de un archivo para crear dentro del contenedor.

  3. Deje otras opciones en valores predeterminados y seleccione Guardar para guardar la configuración.

    Captura de pantalla que muestra la página Configuración de salida de Stream Analytics.

Definir la consulta de transformación

Define una consulta que filtre los datos en streaming y envíe los resultados a la salida.

  1. Abra Script.asaql desde el Explorador de soluciones en Visual Studio.

  2. Agregue la consulta siguiente:

    SELECT *
INTO Output
FROM Input
WHERE Temperature > 27

Envío de una consulta de Stream Analytics a Azure

Envía la consulta a Azure para crear el trabajo de Stream Analytics.

  1. En el Editor de consultas, seleccione Enviar a Azure en el editor de scripts.

  2. En la ventana Enviar trabajo , seleccione Crear un nuevo trabajo de Azure Stream Analytics.

  3. Escriba un nombre de trabajo.

  4. Elija la suscripción de Azure.

  5. Elija el grupo de recursos.

  6. Mantenga el valor predeterminado para Cluster.

  7. Selecciona la ubicación que usaste al principio del inicio rápido.

  8. Seleccione Enviar.

    Captura de pantalla que muestra el cuadro de diálogo Enviar trabajo.

Ejecutar el simulador

Ejecuta el simulador Raspberry Pi para enviar datos de muestra de sensores a tu hub IoT.

  1. Abra Raspberry Pi Azure IoT Online Simulator en una nueva pestaña o ventana del navegador.

  2. Reemplace el marcador de posición de la línea 15 por la cadena de conexión del dispositivo de Azure IoT Hub que guardó en una sección anterior.

  3. Seleccione Ejecutar. La salida debería mostrar los datos de los sensores y los mensajes enviados a tu hub IoT.

    Captura de pantalla que muestra el simulador en línea de Azure IoT de Raspberry Pi.

Inicio del trabajo de Stream Analytics y comprobación de la salida

Inicia el trabajo y comprueba que procesa eventos de entrada y escribe los datos de salida en el almacenamiento de blobs.

  1. Cuando creas tu trabajo, la vista de trabajo se abre automáticamente. Selecciona el botón de flecha verde para empezar el trabajo.

    Captura de pantalla que muestra el botón Iniciar para iniciar un trabajo de Stream Analytics desde Visual Studio.

  2. Cambie el modo de inicio de salida del trabajo a JobStartTime y seleccione Iniciar.

    Captura de pantalla que muestra el cuadro de diálogo Iniciar trabajo de Stream Analytics.

  3. El estado del trabajo cambia a En Ejecución, y aparecen eventos de entrada y salida. Este cambio puede tardar unos minutos. Seleccione el botón Actualizar de la barra de herramientas para actualizar las métricas.

    Captura de pantalla que muestra el estado del trabajo como en ejecución y métricas para el trabajo.

  4. Para ver los resultados, en el menú Ver , selecciona Cloud Explorer y ve a la cuenta de almacenamiento en tu grupo de recursos. Bajo Blob Containers, abre container1 y luego la ruta del archivo de salida.

    Captura de pantalla que muestra los resultados obtenidos en el contenedor de blobs container1.

Limpieza de recursos

Cuando ya no los necesites, elimina el grupo de recursos, el trabajo de streaming y todos los recursos relacionados. Eliminar el trabajo detiene la facturación de las unidades de streaming que consume. Si planeas usar el trabajo en el futuro, para y reinicia el trabajo más adelante cuando lo necesites. Si no planeas volver a usar este trabajo, utiliza los siguientes pasos para eliminar todos los recursos que este inicio rápido ha creado:

  1. Desde el menú izquierdo del portal de Azure, selecciona Grupos de recursos y luego el nombre del recurso que has creado.
  2. En la página del grupo de recursos, seleccione Eliminar, escriba el nombre del recurso que desea eliminar en el cuadro de texto y, a continuación, seleccione Eliminar.

Contenido relacionado

  • Last updated on