Comparteix a través de


Procesamiento y enrutamiento de datos con flujos de datos

Importante

Versión preliminar de operaciones de Azure IoT: habilitada por Azure Arc está actualmente en versión preliminar. No se debería usar este software en versión preliminar en entornos de producción.

Deberá implementar una nueva instalación de Azure IoT Operations cuando esté disponible una versión general. No podrá actualizar una instalación de versión preliminar.

Consulte Términos de uso complementarios para las versiones preliminares de Microsoft Azure para conocer los términos legales que se aplican a las características de Azure que se encuentran en la versión beta, en versión preliminar o que todavía no se han publicado para que estén disponibles con carácter general.

Los flujos de datos permiten conectar varios orígenes de datos y realizar operaciones de datos, simplificando la configuración de rutas de acceso de datos para mover, transformar y enriquecer datos. El componente de flujo de datos forma parte de Operaciones de IoT de Azure, que se implementa como una extensión de Azure Arc. La configuración de un flujo de datos se realiza a través de definiciones de recursos personalizados (CRD) de Kubernetes.

Puede escribir configuraciones para varios casos de uso, como:

  • Transformación de datos y envío a MQTT
  • Transformación de datos y envío a la nube
  • Envío de datos a la nube o el perímetro sin transformación

Los flujos de datos no se limitan a la región donde se implementa la instancia de Operaciones de IoT. Puede usar flujos de datos para enviar datos a puntos de conexión en la nube en diferentes regiones.

Características clave

Estas son las características clave de los flujos de datos.

Procesamiento y enrutamiento de datos

Los flujos de datos permiten la ingesta, el procesamiento y el enrutamiento de los mensajes a los receptores especificados. Puede especificar:

  • Orígenes: de dónde se ingieren los mensajes
  • Destinos: hacia dónde se purgan los mensajes
  • Transformaciones (opcional): configuración para las operaciones de procesamiento de datos

Funcionalidades de transformación

Las transformaciones se pueden aplicar a los datos durante la fase de procesamiento para realizar varias operaciones. Estas operaciones pueden incluir:

  • Proceso de nuevas propiedades: a partir de las propiedades existentes en el mensaje
  • Cambio de nombre de las propiedades: para estandarizar o aclarar los datos
  • Conversión de unidades: convertir valores en diferentes unidades de medida
  • Estandarización de valores: escalar los valores de propiedad a un intervalo definido por el usuario
  • Contextualización de datos: agregar datos de referencia a mensajes para el enriquecimiento y la conducción de información

Configuración e implementación

La configuración se especifica mediante CRD de Kubernetes. En función de esta configuración, el operador de flujo de datos crea instancias de flujo de datos para garantizar una alta disponibilidad y confiabilidad.

Ventajas

  • Configuración simplificada: conecte fácilmente orígenes de datos y destinos.
  • Transformaciones flexibles: realice una amplia gama de operaciones de datos.
  • Configuración escalable: use CRD de Kubernetes para configuraciones escalables y administrables.
  • Alta disponibilidad: el recurso nativo de Kubernetes garantiza la confiabilidad.

Mediante el uso de flujos de datos, puede administrar de forma eficaz las rutas de acceso de datos. Puede asegurarse de que los datos se envían, transforman y enriquecen con precisión para satisfacer sus necesidades operativas.

Registro de esquema

Registro de esquema, una característica proporcionada por la versión preliminar de Azure Device Registry, es un repositorio sincronizado en la nube y en el perímetro. El registro de esquema almacena las definiciones de mensajes procedentes de recursos perimetrales y, a continuación, expone una API para acceder a esos esquemas en el perímetro. Los conectores de southbound, como el conector OPC UA, pueden crear esquemas de mensaje y agregarlos al registro de esquema, o bien los clientes pueden cargar esquemas en la interfaz web de la experiencia de operaciones.

Los flujos de datos usan esquemas de mensajes en los puntos de origen y destino. En el caso de los orígenes, los esquemas de mensaje pueden funcionar como filtros para identificar los mensajes específicos que desea capturar para un flujo de datos. En el caso de los destinos, los esquemas de mensaje ayudan a transformar el mensaje en el formato esperado por el punto de conexión de destino.

Para obtener más información, consulte Descripción de los esquemas de mensaje.