Skip to main content
Para mostrar esta página se usa traducción automática. ¿Ver en inglés en su lugar?
Evolución de la marca 2022
Solución para socios

Tubería de datos de OT contextualizada en Snowflake

¿Cómo podemos recopilar de manera confiable datos de OT independientes del proveedor del taller, enriquecerlos con activos y contexto de producción en el borde, y entregar una copia regida y consultable en Snowflake para análisis, ML y consumo empresarial?

Descripción general

Descripción general del copo de nieve del centro de arquitectura

Una arquitectura híbrida de borde a nube donde Industrial Edge captura, normaliza y contextualiza la telemetría y los eventos de OT, y luego los entrega a Snowflake utilizando patrones de ingestión basados en archivos y de transmisión. Snowflake sirve como la nube de datos empresariales para capas de aterrizaje, seleccionadas y analíticas, lo que permite análisis casi en tiempo real, puntuación de modelos, aplicaciones operativas e integraciones con sistemas MES/ERP/SCADA. El diseño prioriza la consistencia de los datos, la seguridad, la resiliencia y la interoperabilidad independiente del proveedor.

Arquitectura detallada

Colección y contextualización de Edge (Industrial Edge)

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

Descripción

Puentes de protocolo y formato

  • FFT DataBridge (Edge App) transforma y prepara los datos para la ingestión basada en archivos. Se almacena en búfer para manejar la pérdida de conexión, realiza lotes de datos de manera inteligente, se autentica de forma segura con la autenticación del par de claves Snowflake y escribe en las etapas de la nube para el procesamiento de Snowpipe.
  • Snowflake Connector (Edge App) se suscribe al bus de datos para transmisiones continuas, realiza comprobaciones de estado y validación de esquemas, almacena en búfer breves interrupciones en la memoria y utiliza Snowpipe Streaming para insertar filas directamente en Snowflake con baja latencia.

Plataforma de datos Snowflake

  • Ingestión basada en JSON a través de Stage + Pipe (FFT DataBridge): cargas útiles sin procesar aterrizan en un área de espera; Snowpipe /Tasks crea tablas y archivos históricos seleccionados.
  • Ingestión directa basada en filas (Snowpipe Streaming a través de Snowflake Connector): disponibilidad continua y de baja latencia de filas operativas para paneles y monitoreo.
  • Las canalizaciones de transformación (SQL, Snowpark, Streams & Tasks) producen conjuntos de datos seleccionados, alineados en el tiempo y enriquecidos en contexto para BI y ML.
  • Snowflake proporciona gobierno (control de acceso, enmascaramiento, linaje), escalado y capacidades entre nubes para el consumo empresarial.
  • Snowflake se ejecuta de forma nativa y consistente en los principales proveedores de nube (AWS, Microsoft Azure y Google Cloud Platform), ofreciendo una verdadera implementación, replicación y movilidad de datos entre nubes.

Valores y beneficios

Componentes