Creación de paneles de Power BI en tiempo real con el editor sin código de Stream Analytics

En este tutorial se muestra cómo usar el editor sin código de Stream Analytics para calcular agregados en flujos de datos en tiempo real y almacenarlos en Azure Synapse Analytics.

En este tutorial, aprenderá a:

• Implementar un generador de eventos que envía datos al centro de eventos
• Creación de un trabajo de Stream Analytics sin editor de código
• Revisar los datos de entrada y el esquema
• Seleccionar campos para agrupar y definir agregaciones como el conteo
• Configuración de Azure Synapse Analytics en la que se escriben los resultados
• Ejecución del trabajo de Stream Analytics
• Visualización de datos en Power BI

Requisitos previos

Antes de empezar, asegúrese de completar los pasos siguientes:

1. Si no tiene una suscripción a Azure, cree una cuenta gratuita.
2. Implemente el generador de eventos TollApp en Azure. Use este vínculo para implementar la plantilla de Azure TollApp. Establezca el interval parámetro en 1. Use un nuevo grupo de recursos para este paso.
3. Cree un área de trabajo de Azure Synapse Analytics con un grupo de SQL dedicado.
4. Cree una tabla denominada carsummary mediante el grupo de SQL dedicado. Ejecute el siguiente script SQL:

   CREATE TABLE carsummary   
   (  
       Make nvarchar(20),  
       CarCount int,
   	times datetime
   )
   WITH ( CLUSTERED COLUMNSTORE INDEX ) ;
   

Uso del editor sin código para crear un trabajo de Stream Analytics

1. Busque el grupo de recursos donde implementó el generador de eventos TollApp.

2. Seleccione el espacio de nombres de Azure Event Hubs.

3. En la página Espacio de nombres de Event Hubs , seleccione Event Hubs en Entidades en el menú izquierdo.

4. Seleccione la entrystream instancia.

   

5. En la sección Características , vaya a Procesar datos y seleccione Iniciar en la plantilla Inicio con lienzo en blanco .

   

6. Asigne al trabajo el nombre carsummary y seleccione Crear.

   

7. En la página de configuración del centro de eventos, confirme la siguiente configuración y, a continuación, seleccione Conectar.

   1. En el grupo de consumidores, seleccione Usar existente y a continuación seleccione Valor predeterminado.

   2. Para tipo de serialización, confirme que JSON está seleccionado.

   3. Para modo de autenticación, confirme que Cadena de conexión se usa para conectarse al centro de eventos: Cadena de conexión.

      

8. En unos segundos, verá los datos de entrada de ejemplo y el esquema. Puede elegir quitar campos, cambiar el nombre de los campos o cambiar los tipos de datos.

   

9. Seleccione Operaciones en la barra de comandos y, a continuación, seleccione Agrupar por.

   

10. Seleccione el icono Agrupar por en el lienzo y conéctelo al icono del centro de eventos.

    

11. Para configurar el icono Agrupar por, especifique:

    1. En Agregación, seleccione Recuento.

    2. Campo como Make, que es un campo anidado dentro de CarModel.

    3. Seleccione Agregar.

       

    4. En la sección Configuración:

       1. Para Agrupar agregaciones por, seleccione Crear.

       2. En Período de tiempo, confirme que el valor está establecido en Ventana fija.

       3. En Duración, escriba 3 minutos.

       4. Seleccione Listo en la parte inferior de la página.

          

12. Seleccione Agrupar por, y observe los datos agrupados en la vista previa de datos de la pestaña en la parte inferior de la página.

    

13. En la barra de comandos, seleccione Operaciones y, a continuación , Administrar campos.

14. Conecte los iconos Agrupar por y Administrar campos.

15. En la página Administrar campos, siga estos pasos:

    1. Agregue el campo Make como se muestra en la imagen siguiente y, a continuación, seleccione Agregar.

       

    2. Seleccione Agregar.

       

16. Seleccione Agregar todos los campos en la página de configuración Administrar campos.

    

17. Seleccione el botón ... situado junto a los campos y seleccione Editar para cambiarles el nombre.

    • COUNT_make a CarCount

    • Window_End_Time a tiempos

      

18. Seleccione Listo en la página Administrar campos. La página Administrar campos debe tener el aspecto que se indica en la página siguiente.

    

19. Seleccione el icono Administrar campos, y vea los datos que fluyen a la operación en la pestaña Vista previa de datos en la parte inferior de la página.

    

20. En la barra de comandos, seleccione Salidas, y después, Synapse.

    

21. Conecte el icono de Synapse al icono Administrar campos del lienzo.

22. En la página de configuración de Synapse, siga estos pasos:

    1. Si la cuenta de almacenamiento de trabajo aún no está establecida, seleccione la cuenta de Azure Data Lake Storage en el grupo de recursos. Es la cuenta de almacenamiento que utiliza Synapse SQL para cargar datos en su almacén de datos.

       

    2. Seleccione la suscripción de Azure donde se encuentra Azure Synapse Analytics.

    3. Seleccione la base de datos del grupo de SQL dedicado que usó para crear la tabla carsummary en la sección anterior.

    4. Escriba el nombre de usuario y la contraseña para autenticarse.

    5. Escriba el nombre de la tabla como carsummary.

    6. Seleccione Conectar. Verá los resultados de ejemplo que se escriben en su tabla de SQL de Synapse.

       

23. Seleccione icono de Synapse y vea la pestaña Vista previa de datos en la parte inferior de la página. Verá cómo los datos fluyen hacia el grupo de SQL dedicado.

    

24. Seleccione Guardar en la cinta de opciones superior para guardar el trabajo y, a continuación, seleccione Iniciar.

25. En la página Iniciar trabajo de Stream Analytics, seleccione Iniciar para ejecutar el trabajo.

    

26. A continuación, verá una lista de todos los trabajos de Stream Analytics creados sin el editor de código. Y luego de menos de dos minutos, el trabajo cambia a un estado En ejecución. Seleccione el botón Actualizar de la página para ver el cambio de estado de Creado a Iniciando y luego a Ejecutando.

    

Creación de una visualización de Power BI

1. Descargue la versión más reciente de Power BI Desktop.

2. Use el conector de Power BI para Azure Synapse SQL.

   

3. Conéctese a la base de datos mediante DirectQuery y use esta consulta para capturar datos de la base de datos.

   SELECT [Make],[CarCount],[times]
   FROM [dbo].[carsummary]
   WHERE times >= DATEADD(day, -1, GETDATE())
   

   

   Cambie a la pestaña Base de datos y escriba sus credenciales (nombre de usuario y contraseña) para conectarse a la base de datos y ejecutar la consulta.

4. Seleccione Cargar para cargar datos en Power BI.

5. Después, puede crear un gráfico de líneas con

   • El eje X como las horas
   • El eje Y como CarCount
   • Leyenda de cómo ver un gráfico para publicar. Puede configurar la actualización automática de páginas y establecerla en 3 minutos para obtener una vista en tiempo real.

Más opciones

Además de Azure Synapse SQL, también puede usar SQL Database como salida del editor sin código para recibir los datos de streaming. A continuación, use el conector de Power BI para conectarse a una base de datos SQL con su base de datos mediante DirectQuery para construir el panel en tiempo real.

También es una buena opción crear el panel en tiempo real con datos en streaming. Para más información sobre la salida de SQL Database, consulte Transformar e incorporar a SQL Database.

Limpieza de recursos

1. Busque la instancia de Event Hubs y vea la lista de trabajos de Stream Analytics en la sección Procesar datos . Detenga los trabajos en ejecución.
2. Vaya al grupo de recursos que usó al implementar el generador de eventos de TollApp.
3. Seleccione Eliminar grupo de recursos. Para confirmar la eliminación, escriba el nombre del grupo de recursos.

Pasos siguientes

En este tutorial, ha creado un trabajo de Stream Analytics sin el editor de código para definir agregaciones y escribir resultados en Azure Synapse Analytics. Después, usó Power BI para crear un panel en tiempo real para ver los resultados generados por el trabajo.

Procesamiento de flujos sin código con Azure Stream Analytics