Skip to main content
Esta página se muestra mediante traducción automática. ¿Deseas ver el contenido en inglés?
Evolución de la marca 2022
Solución de socios

Canalización de datos de OT contextualizada hacia Snowflake

¿Cómo podemos recopilar de forma fiable datos de OT independientes del proveedor del taller, enriquecerlos con el contexto de activos y producción en el borde y ofrecer una copia gobernada y consultable en Snowflake para el análisis, el aprendizaje automático y el consumo empresarial?

Información general

descripción general de Architecture Hub Snowflake

Una arquitectura híbrida de extremo a nube en la que Industrial Edge captura, normaliza y contextualiza la telemetría y los eventos del OT y, luego, los entrega a Snowflake mediante patrones de ingesta basados en archivos y en streaming. Snowflake actúa como nube de datos empresarial para las capas de destino, selección y análisis, lo que permite el análisis casi en tiempo real, la puntuación de modelos, las aplicaciones operativas y la integración con los sistemas MES/ERP/SCADA. El diseño prioriza la coherencia de los datos, la seguridad, la resiliencia y la interoperabilidad independiente del proveedor.

Arquitectura detallada

Recopilación perimetral y contextualización (Industrial Edge)

  • Industrial Edge ejecuta dispositivos locales cerca del taller y se conecta a equipos de automatización independientes del proveedor mediante conectores OT (OPC UA, Modbus, EtherNet/IP, etc.). Adquiere telemetría, alarmas y eventos sin procesar.
  • En el borde, los datos se preprocesan: filtrado, compresión, normalización de la marca horaria, enriquecimiento con los metadatos de los activos (jerarquías de activos, órdenes de trabajo/contexto por lotes) y agregación local para reducir el ancho de banda de la nube.
  • Un bus de datos interno (MQTT/Unified Namespace) o Industrial Information Hub propaga flujos de temas armonizados para los componentes posteriores y los consumidores locales.
Architecture Hub, copo de nieve, gráfico detallado, sin texto

Descripción

Puenteo de protocolos y formatos

  • La FFT DataBridge (aplicación Edge) transforma y prepara los datos para la ingestión basada en archivos. Se almacena en búfer para gestionar la pérdida de conexión, agrupa los datos de forma inteligente, se autentica de forma segura con la autenticación de pares de claves de Snowflake y escribe en escenarios de nube para procesarlos con Snowpipe.
  • Snowflake Connector (aplicación Edge) se suscribe al bus de datos para obtener transmisiones continuas, realiza la validación del esquema y las comprobaciones de estado, almacena en búfer las interrupciones breves de la memoria y utiliza Snowpipe Streaming para insertar filas directamente en Snowflake con baja latencia.

Plataforma de datos Snowflake

  • Ingesta basada en JSON a través de Stage + Pipe (FFT DataBridge): las cargas útiles sin procesar llegan a una zona de ensayo; Snowpipe/Tasks crea tablas seleccionadas y archivos históricos.
  • Ingesta directa por filas (transmisión de Snowpipe a través de Snowflake Connector): disponibilidad continua y de baja latencia de las filas operativas para los paneles de control y la monitorización.
  • Los procesos de transformación (SQL, Snowpark, Streams & Tasks) producen conjuntos de datos seleccionados, alineados en el tiempo y enriquecidos con el contexto para BI y ML.
  • Snowflake proporciona capacidades de gobierno (control de acceso, enmascaramiento, linaje), escalado y entre nubes para el consumo empresarial.
  • Snowflake se ejecuta de forma nativa y coherente en los principales proveedores de nube (AWS, Microsoft Azure y Google Cloud Platform), lo que ofrece un verdadero despliegue, replicación y movilidad de datos entre nubes.

Valores y beneficios

Componentes