Principais Atualizações

• Aprimoramentos SQL: Novas funções como detecção de alterações e object_construct para maior expressividade em regras de análise
• Conexões de ecossistema: Suporte nativo para integração com Neuron e conectores SQL universais para bancos relacionais
• Melhorias operacionais: Maior estabilidade de regras, isolamento de procesos e compilação seletiva para dispositivos com restrições

Conexões com Ecossistemas

Fontes e sinks ampliam a conectividade do eKuiper. A versão 1.5.0 introduz suporte para Neuron e conectores SQL genéricos, além de melhorias em sinks como o TDengine com tabelas avançadas.

Integração Neuron

Neuron, gateway indusrtial de código aberto, converte protocolos industriais para MQTT. A integração direta elimina a necessiadde de brokers MQTT intermediários e simplifica fluxos de coleta e controle. Comunicação via NNG reduz consumo de rede.

CRIAR FLUXO sensor_data() COM (TIPO="neuron", COMPARTILHADO="VERDADEIRO")

Controle reverso via ação Neuron:

"neuron": {
  "nomeNo": "{{.nodo}}",
  "nomeGrupo": "grupo_a",
  "marcadores": ["sensor01"]
}

Acesso SQL Universal

Conectores SQL permitem conversão de dados batch em fluxos:

• Source SQL: Pull periódico com deduplicação para bancos como MySQL e PostgreSQL
• Sink SQL: Inserção genérica (bancos especializados usam plugins dedicados)

Aprimoramentos SQL

Novas funções ampliam capacidades analíticas:

Detecção de Alterações

Funções para monitoramento dinâmico de colunas:

• COLUNAS_ALTERADAS: Retorna múltiplas colunas modificadas
• COLUNA_ALTERADA: Filtra por alterações específicas
• HOUVE_ALTERACAO: Verifica estado de mudanças

Agrupamento de Dados

Função object_construct estrutura saídas em grupos nomeados:

SELECT 
  object_construct("grupoA", temp, "grupoB", umid) AS relatorio1,
  object_construct("grupoC", pressao) AS relatorio2 
FROM fluxo_principal

Saída em JSON estruturado:

{
  "relatorio1": {"grupoA": 22.5, "grupoB": 80},
  "relatorio2": {"grupoC": 1013}
}

Operação Otimizada

Melhorias em ambientes de produção:

Isolamento de Regras

• Falhas não propagadas entre regras com fontes compartilhadas
• Gerenciamento independente de carga para fluxos paralelos

Compilação Seletiva

Builds personalizados via tags Go para dispositivos restritos:

make compilar_core  # Binário mínimo para hardware limitado

Atualização

Alterações críticas para migração:

1. Configuração MQTT: "servers" → "servidor" (string única)
2. Sink TDengine: "ip" → "host" (exige nome de domínio)