Com mais de dez anos de experiência na construção de sistemas de aquisição de informações sobre o uso de energia elétrica, combinando os desafios no contexto da nova situação da reforma da energia elétrica baseada no mercado, a Dongsoft construiu uma plataforma de aquisição de informações de energia integrada perfeita e unificada, realizando a aquisição e o processamento de informações de energia elétrica em três pontos do lado da compra de energia, do lado do fornecimento de energia e do lado da venda de energia elétrica, apoiando a aquisição direta de dados de energia elétrica de grandes terminais especializados, terminais especializados de pequeno e médio tamanho, concentradores e medidores de energia com funções de comunicação, implementando totalmente todos os tipos de dados de informações de energia elétrica de usuários, incluindo a aquisição de dados de energia elétrica de pequenas instalações hidroeléctricas, pequenas instalações térmicas, geração de energia fotovoltaica e pontos de medição de Ao mesmo tempo, a plataforma integrada de coleta de informações energéticas permite a coleta, tratamento, armazenamento e distribuição centralizadas de água, eletricidade, calor e gás.

A arquitetura de aplicação da plataforma integrada de aquisição de informações de energia da Dongsoft pode ser dividida de baixo para cima em três níveis de "plataforma de suporte", "plataforma de aquisição" e "aplicação de negócios", como mostrado no gráfico abaixo:

Plataforma de suporteAplicativos de suporte como base, incluindo plataforma de desenvolvimento integrada unificada da Dongsoft, plataforma de interação de interface, funções de suporte ao fluxo de trabalho, gerenciamento de pessoas e sistemas de permissões, mecanismo de alarme, plataforma de mensagens de texto públicas, sistema de correio, etc.

Plataforma de coletaDivide-se em domínios de pré-comunicação e processamento de dados. O sistema de comunicação frontal é composto por servidores de comunicação, servidores de gerenciamento, equipamentos de balanceamento de carga, etc. Complete o acesso ao terminal, regula a recepção de mensagens, análise, combinação, embalagem de mensagens, armazenamento de dados, balanceamento de carga e outras funções. O processamento de dados completa a configuração do estatuto de coleta, a configuração do conteúdo de coleta, o gerenciamento da estratégia de coleta, a emissão de instruções, o julgamento da integridade da mensagem, o cálculo inicial de dados e outras funções.

Camada de Aplicação de NegóciosA camada de suporte da plataforma e a plataforma de aquisição é a plataforma integrada de aquisição de informações de energia para empresas de energia elétrica fornecer uma rica variedade de funções de aplicação, além das funções básicas, tais como: gerenciamento de arquivos, gerenciamento de terminais, gerenciamento de tarefas de aquisição, processamento de dados, consulta de dados, etc., também inclui funções necessárias para a operação estável do sistema, tais como: monitoramento operacional, gerenciamento operacional e manutenção, ao mesmo tempo que a plataforma integrada de aquisição de informações de energia fornece um nível mais alto de gerenciamento de negócios e aplicações de análise de dados grandes, tais como: gerenciamento de controle de custos, gerenciamento de perdas de linhas, análise de energia, análise de carga, previsão de carga, análise de anormalidades de equipamentos de medição, etc.

A Dongsoft aproveita o conceito de design SOA orientado ao serviço, com a perspectiva de especialização técnica e profissionalização de negócios, para otimizar a arquitetura e atualizar o sistema de aquisição de informações sobre o uso de eletricidade dos usuários de eletricidade existentes da Dongsoft. Tecnicamente, ele pode atender às necessidades de aquisição de pequenas empresas de venda de eletricidade (empresas de fornecimento de eletricidade), ao mesmo tempo que pode expandir suavemente para a rede de eletricidade local e municipal e até a rede de eletricidade provincial em escala de coleta de dados, processamento, armazenamento e aplicação; Implantação de acoplamento solto entre módulos, segmentação e combinação de software de acordo com as necessidades da aplicação e troca de dados baseada no modelo IEC CIM que atende às normas internacionais.

Quando as pequenas e médias empresas de fornecimento de energia com tamanho de terminais abaixo de 100.000 e usuários abaixo de 2 milhões, a arquitetura tecnológica adotada pela plataforma integrada de coleta de informações energéticas (todas baseadas em componentes de plataforma de software de código aberto) é a seguinte:

Os componentes de aquisição são desacoplados com um barramento de dados em tempo real para implementação flexível conforme necessário.

Quando o tamanho de usuários chega a mais de 10 milhões, componentes como o ônibus de dados em tempo real são substituídos por computação e armazenamento distribuídos para alcançar um alto desempenho empresarial, com a arquitetura técnica mostrada abaixo:

Características técnicas

Capacidade de coleta e processamento de dados de alto desempenho

As necessidades de dados de alta frequência exigem capacidade de coleta de dados de alto desempenho, emissão de instruções conveniente, resolução de estatutos de alto desempenho e processamento de dados em banco de dados de alta velocidade

• Introdução de processamento paralelo e tecnologia de cache distribuída para melhorar a capacidade de processamento de dados coletados
• Introdução de filas de mensagens distribuídas para melhorar a capacidade de interação de mensagens no master e no prefix
• Introdução de armazenamento de dados distribuído para resolver gargalos de E/S de banco de dados

Capacidade diferenciada de gerenciamento de dados

A transmissão de alta densidade e a publicação de vários tipos de dados de coleta, portanto, como gerenciar a coleta de dados e a publicação eficiente de dados é um novo requisito de aplicação para o sistema de coleta

• Introdução de bancos de dados distribuídos HBase para resolver os gargalos de armazenamento de dados grandes em bancos de dados relacionais tradicionais
• O gigantesco cluster global HBase (Facebook) realiza 1,5 milhão de operações por segundo, aumentando 250 TB por mês
• Distribuição automática da carga de leitura de dados com base em tecnologia de banco de dados distribuído (armazenamento de dados redundante, etc.)
• Consulta de um residente de baixa pressão, dados congelados diariamente por um mês, resposta em milissegundos
• Os dados em tempo real são gravados no cache distribuído no mesmo dia, proporcionando acesso aos dados com alta frequência no centro de negociação. A velocidade de leitura atinge 110.000 vezes por segundo e a velocidade de escrita atinge 81.000 vezes por segundo.
• Um único servidor baseado em filas de mensagens distribuídas pode fornecer 100 megabytes de dados por segundo para milhares de clientes ao mesmo tempo

Armazenamento Distribuído de Dados com o Hadoop HDFS

• É um sistema de arquivos distribuído altamente tolerante a erros, projetado para ser executado em hardware de baixo custo.
• O HDFS oferece acesso a dados de aplicativos de alta throughput para aplicativos com grandes conjuntos de dados
• HBase é um sistema de armazenamento de colunas altamente confiável, de alto desempenho, orientado a colunas e altamente escalável, construído sobre o HDFS; HBase é um sistema de chave/valor típico.
• Usado para armazenamento de dados estruturados em massa, aumenta a capacidade de computação e armazenamento através do aumento contínuo de servidores comerciais baratos.

Capacidade de análise e mineração de dados de alto desempenho

Computação, análise e mineração de dados em pouco tempo

• Melhore o desempenho do processamento de análise de dados com base no Map Reduce
• Armazenamento de dados distribuído reduz gargalos de E/S de um só nó e melhora a eficiência da leitura
• Mineração de dados complexa com base em cálculos de memória Spark - análise de cluster, etc.
• Por exemplo, o monitoramento on-line e a análise de diagnóstico inteligente, com base em computação distribuída e tecnologia de armazenamento distribuído, 29 tópicos de análise são todos contados em 1 hora, com 10 vezes maior eficiência
• Melhore desempenho de cálculo através da escalabilidade horizontal

Capacidade eficiente de publicação e troca de dados

• Transformação de "extração de dados" para "publicação de dados"
• Acesso simultâneo e de alta frequência aos dados baseado em armazenamento de dados distribuído
• Fornecer uma forma de assinatura web para monitoramento sincronizado real em tempo real com o sistema de captura
• Com base em filas de mensagens distribuídas, garantir a pontualidade e a sequência das instruções de interrupção de energia
• Criptografia de informações para interações de informações críticas de unidades externas (classe de controle)