Skip to main content
Esta página é apresentada utilizando tradução automática. Prefere ver em inglês?
Evolução da Marca 2022
Solução de Parceiro

Pipeline de dados OT contextualizado no Snowflake

Como podemos recolher de forma fiável dados de OT independentes do fornecedor do chão de fábrica, enriquecê-lo com ativos e contexto de produção na borda e entregar uma cópia governada e consultável no Snowflake para análise, ML e consumo empresarial?

Visão geral

visão geral do floco de neve do hub de arquitetura

Uma arquitetura híbrida de ponta a nuvem onde o Industrial Edge captura, normaliza e contextualiza a telemetria e os eventos de OT e, em seguida, os entrega ao Snowflake usando padrões de ingestão baseados em arquivo e streaming. O Snowflake serve como a cloud de dados empresariais para camadas de aterragem, curadoria e analíticas, permitindo análises quase em tempo real, pontuação de modelos, aplicações operacionais e integrações com sistemas MES/ERP/SCADA. O design prioriza a consistência dos dados, a segurança, a resiliência e a interoperabilidade independente do fornecedor.

Arquitetura detalhada

Coleta de borda e contextualização (Industrial Edge)

  • O Industrial Edge executa dispositivos locais perto do chão de fábrica e liga-se a equipamentos de automação independentes do fornecedor através de conectores OT (OPC UA, Modbus, Ethernet/IP, etc.). Adquire telemetria bruta, alarmes e eventos.
  • No limite, os dados são pré-processados: filtragem, compressão, normalização do carimbo de data/hora, enriquecimento com metadados de ativos (hierarquias de ativos, ordem de serviço/contexto em lote) e agregação local para reduzir a largura de banda na nuvem.
  • Um banco de dados interno (MQTT/Unified Namespace) ou Industrial Information Hub propaga fluxos de tópicos harmonizados para componentes downstream e consumidores locais.
hub de arquitetura floco de neve gráfico detalhado sem texto

Descrição

Protocolo e ponte de formato

  • O FFT DataBridge (Edge App) transforma e prepara dados para ingestão baseada em ficheiros. Ele guarda bufffers para lidar com a perda de conexão, agrupa dados de forma inteligente, autentica de forma segura com a autenticação do par de chaves Snowflake e grava em estágios de nuvem para processamento de Snowpipe.
  • O Snowflake Connector (Edge App) subscreve o banco de dados para fluxos contínuos, realiza validação de esquema e verificações de integridade, protege interrupções curtas na memória e usa o Snowpipe Streaming para inserir linhas diretamente no Snowflake com baixa latência.

Plataforma de dados Snowflake

  • Ingestão baseada em JSON via Stage + Pipe (FFT DataBridge): cargas úteis brutas aterram numa área de espera; Snowpipe /Tasks criam tabelas selecionadas e arquivos históricos.
  • Ingestão direta baseada em linha (Snowpipe Streaming via Snowflake Connector): disponibilidade contínua e de baixa latência de linhas operacionais para painéis e monitorização.
  • Os pipelines de transformação (SQL, Snowpark, Streams & Tasks) produzem conjuntos de dados com curadoria, alinhados no tempo e enriquecidos com o contexto para BI e ML.
  • O Snowflake fornece governança (controlo de acesso, mascaramento, linhagem), escalabilidade e capacidades entre nuvens para consumo empresarial.
  • O Snowflake é executado de forma nativa e consistente nos principais fornecedores de cloud (AWS, Microsoft Azure e Google Cloud Platform), oferecendo uma verdadeira implementação entre nuvens, replicação e mobilidade de dados.

Valores & benefícios

Componentes