Leer en inglés

Compartir a través de


Transmisión de datos en Azure SQL Database mediante la integración de Azure Stream Analytics (versión preliminar)

Ahora los usuarios pueden ingerir, procesar, ver y analizar datos de transmisión en tiempo real en una tabla directamente desde una base de datos en Azure SQL Database. Lo hacen en Azure Portal mediante Azure Stream Analytics. Esta experiencia permite una amplia variedad de escenarios, como automóviles conectados, supervisión remota, detección de fraudes y muchos más. En Azure Portal, puede seleccionar un origen de eventos (Event Hub o IoT Hub), ver eventos entrantes en tiempo real y seleccionar una tabla para almacenar eventos. También puede escribir consultas de lenguaje de consulta de Azure Stream Analytics en el portal para transformar los eventos entrantes y almacenarlos en la tabla seleccionada. Este nuevo punto de entrada se suma a las experiencias de creación y configuración que ya existen en Stream Analytics. Esta experiencia se inicia en el contexto de la base de datos, lo que le permite configurar rápidamente un trabajo de Stream Analytics y navegar sin problemas entre la base de datos de Azure SQL Database y las experiencias de Stream Analytics.

Stream Analytics flow

Ventajas principales

  • Cambio de contexto mínimo: puede empezar a partir de una base de datos en Azure SQL Database en el portal y comenzar a ingerir datos en tiempo real en una tabla sin cambiar a ningún otro servicio.
  • Número reducido de pasos: el contexto de la base de datos y la tabla se usa para configurar previamente un trabajo de Stream Analytics.
  • Facilidad de uso adicional con vista previa de los datos: obtenga una vista previa de los datos entrantes desde el origen de eventos (Event Hub o IoT Hub) en el contexto de la tabla seleccionada

Importante

Un trabajo de Azure Stream Analytics puede generar salida en Azure SQL Database, Azure SQL Managed Instance o Azure Synapse Analytics. Para más información, vea Salidas.

Requisitos previos

Para completar los pasos de este artículo, necesitará los siguientes recursos:

Configuración de la integración de Stream Analytics

  1. Inicie sesión en Azure Portal.

  2. Vaya a la base de datos en la que quiera ingerir los datos de transmisión. Seleccione Stream Analytics (versión preliminar) .

    Stream Analytics

  3. Para empezar a ingerir los datos de transmisión en esta base de datos, seleccione Crear, asigne un nombre al trabajo de transmisión y, después, seleccione Siguiente: Entrada.

    configure Stream Analytics job basics

  4. Escriba los detalles del origen del evento y, después, seleccione Siguiente: Salida.

    • Tipo de entrada: Event Hub/IoT Hub

    • Alias de entrada: escriba un nombre para identificar el origen del evento

    • Suscripción: igual que la suscripción a Azure SQL Database

    • Espacio de nombres del centro de eventos: nombre del espacio de nombres

    • Nombre del centro de eventos: nombre del centro de eventos en el espacio de nombres seleccionado

    • Nombre de directiva de centro de eventos (de forma predeterminada se crea uno): proporcione un nombre de directiva

    • Grupo de consumidores del Centro de eventos (de forma predeterminada se crea uno): proporcione un nombre para el grupo de consumidores

      Se recomienda crear un grupo de consumidores y una directiva para cada trabajo de Azure Stream Analytics que cree desde aquí. 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.

      configure Stream Analytics job output

  5. Seleccione la tabla en la que quiera ingerir los datos de transmisión. Cuando haya terminado, seleccione Crear.

    • Nombre de usuario, Contraseña: escriba las credenciales para la autenticación de SQL Server. Seleccione Validar.

    • Tabla: seleccione Crear nueva o Usar existente. En este flujo, seleccionemos Crear. Esto creará una tabla al iniciar el trabajo de Stream Analytics.

      create Stream Analytics job

  6. Se abre una página de consulta con los detalles siguientes:

    • La Entrada (origen del evento de entrada) desde la que se ingerirán los datos

    • La Salida (tabla de salida) que almacenará los datos transformados

    • Una consulta SAQL de ejemplo con la instrucción SELECT.

    • Vista previa de entrada: muestra la instantánea de los datos entrantes más recientes del origen del evento de entrada.

      • 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.
      • Seleccione Seleccionar intervalo de tiempo para probar la consulta con un intervalo de tiempo específico de eventos entrantes.
      • Seleccione Cargar entrada de muestra para probar la consulta mediante la carga de un archivo JSON o CSV de ejemplo. Para más información sobre cómo probar una consulta de SAQL, vea Prueba de un trabajo de Azure Stream Analytics con datos de ejemplo.

      test query

    • Resultados de la prueba: seleccione Consulta de prueba y podrá ver los resultados de la consulta de streaming.

      test results

    • Esquema de resultados de la prueba: muestra el esquema de los resultados de la consulta de streaming después de la prueba. Asegúrese de que el esquema de resultados de la prueba coincide con el esquema de salida.

      test results schema

    • Esquema de salida: contiene el esquema de la tabla que ha seleccionado en el paso 5 (nueva o existente).

      • Crear nuevo: si seleccionó esta opción en el paso 5, aún no verá el esquema hasta que inicie el trabajo de streaming. Al crear una tabla, seleccione el índice de tabla adecuado. Para más información sobre la indexación de tablas, vea Índices agrupados y no agrupados descritos.
      • Usar existente: si ha seleccionado esta opción en el paso 5, verá el esquema de la tabla seleccionada.
  7. Cuando haya terminado de crear y probar la consulta, seleccione Guardar consulta. Seleccione Iniciar el trabajo de Stream Analytics para empezar a ingerir los datos transformados en la tabla SQL. Una vez que haya finalizado los campos siguientes, inicie el trabajo.

    • Hora de inicio de salida: define la hora de la primera salida del trabajo.

    • Unidades de streaming: Los precios de Azure Stream Analytics se basan en el número de unidades de streaming necesarias para procesar los datos en el servicio. Para más información, vea los precios de Azure Stream Analytics.

    • Control de errores de datos de salida:

      • Reintento: Si se produce un error, Azure Stream Analytics volverá a intentar la escritura del evento indefinidamente hasta que esta se realice correctamente. No hay ningún tiempo de expiración para los reintentos. En última instancia, el evento que se está reintentando bloqueará todos los eventos posteriores del procesamiento. Esta opción es la directiva de control de errores de salida predeterminada.
      • Quitar: Azure Stream Analytics anulará todos los eventos de salida que produzcan un error de conversión de datos. No se pueden recuperar los eventos anulados para volver a procesarlos más adelante. Todos los errores transitorios (por ejemplo, errores de red) se reintentan independientemente de la configuración de la directiva de control de errores de salida.
    • Configuración de salida de SQL Database: Opción para heredar el esquema de partición del paso de consulta anterior a fin de habilitar la topología completamente paralela con múltiples escritores en la tabla. Para obtener más información, vea Salida de Azure Stream Analytics a Azure SQL Database.

    • Número máximo de lotes: Número máximo de registros recomendado para enviarse con cada transacción de inserción masiva.
      Para más información sobre el control de errores de salida, vea Directivas de errores de salida en Azure Stream Analytics.

      start job

  8. Una vez que haya iniciado el trabajo, verá el trabajo en ejecución en la lista y podrá realizar las acciones siguientes:

    • Iniciar o detener el trabajo: si el trabajo está en ejecución, lo puede detener. Si el trabajo está detenido, lo puede iniciar.

    • Editar trabajo: puede modificar la consulta. Si quiere realizar más cambios en el trabajo, agregar más entradas o salidas, y después abrirlo en Stream Analytics. La opción Editar está deshabilitada cuando el trabajo está en ejecución.

    • Vista previa de la tabla de salida: puede obtener una vista previa de la tabla en el editor de consultas SQL.

    • Abrir en Stream Analytics: abra el trabajo en Stream Analytics para ver, supervisar y depurar los detalles del trabajo.

      stream analytics jobs

Pasos siguientes