Plataforma de integração convergente H3C

A plataforma Xinhua Three Oasis é uma plataforma de base digital com a filosofia de quebrar a "ilha isolada da informação" e eliminar a "chaminé de dados", ajudando as empresas a usar os dados para obter o máximo valor dos dados.

A plataforma de integração de convergência Oasis oferece APIs, mensagens e integração de dados para todos os tipos de sistemas de negócios, protege as diferenças de sistema subjacentes para aplicativos de negócios, oferece suporte de serviço unificado e ajuda os desenvolvedores a desenvolver rapidamente a capacidade de integrar sistemas existentes e integrar sistemas para atender às ricas necessidades de conectividade no processo de digitalização.

A plataforma de integração convergente Oasis inclui capacidades como integração de mensagens, integração de serviços, integração de dados, gerenciamento de recursos e outras, através da conexão com a plataforma de operações de dados, fornecendo modelos de dados padrão para formar vários modelos de dados de negócios. Desenvolver ativos para criar modelos de APIs comumente usadas, reutilizar e acelerar a prestação de serviços externos. Além disso, o desenvolvimento de scripts de orquestração de dados de uso comum, encapsulamento de capacidade genérica, realizando reutilização de capacidade e evitando duplicações. A abertura externa fornece interfaces padronizadas e modelos de serviços, como reconhecimento facial, síntese de voz, etc., como saídas de capacidade padrão, sem que o usuário precise configurar operações em plataformas de integração convergente. Padronizar o modelo de serviço para permitir a rápida reutilização e desenvolvimento externo do modelo de serviço.

Massiva integração de dados heterogêneos

A complexidade e diversidade dos sistemas de negócios empresariais, por um lado, traz a diversidade de tipos de dados, como dados de bancos de dados relacionais tradicionais, mensagens API、 Arquivos e outros desafiam a integridade funcional da integração de dados. Por outro lado, à medida que os negócios crescem, o volume de dados cresce explosivamente, o que representa um grande desafio para a eficiência da integração de dados. Plataforma integrada de convergência Oasis que suporta mais de 30 tipos de fontes de dados para fornecer dados, mensagens, API、 Várias capacidades de integração, como protocolos IoT, incluindo integração de dados para lotes e cenários em tempo real e serviços de integração eficientes e seguros para aplicativos, permitem uma plataforma integrada para a integração de grandes quantidades de dados heterogêneros.

Filas de mensagens distribuídas orientadas por eventos

O dispositivo da IoT captura a mensagem de evento gerada por eventos, a mensagem de evento fornece uma fila de mensagens distribuída unificada em tempo real através da plataforma de integração de convergência, o sistema de processamento inteligente de eventos obtém a mensagem de evento correspondente ao consumo através da consulta e assinatura de eventos, o evento após o processamento ou a mensagem de caso formada pelo fluxo, a transmissão em tempo real da mensagem integrada pela plataforma de integração de convergência, o relatório e a emissão adotam diferentes canais de dados, impulsionando o dispositivo da IoT para o processamento correspondente, como o interruptor do gateway, o interruptor do dispositivo de iluminação inteligente e outras ações correspondentes. O fluxo de eventos é impulsionado pelo uso de mecanismos unificados de acesso a mensagens e canais de mensagens padronizados, reduzindo os custos de acoplamento do sistema resultantes do uso de diferentes componentes de mensagens.

Centro de fluxo de eventos seguro e eficiente

A plataforma de integração de convergência Oasis oferece um sistema de canalização de mensagens em tempo quase real persistente e de alta throughput, compatível com recursos nativos de processamento de mensagens Kafka para suportar a transmissão segura de mensagens. A publicação / assinatura de mensagens reforça o controle de acesso à rede através da certificação SASL, criptografia SSL, grupos de segurança, etc., fornecendo armazenamento de eventos, consultas de eventos, assinaturas de eventos, publicação de eventos, monitoramento de eventos e outros canais de acesso eficientes para eventos geradores e consumidores, fornecendo serviços de processamento de mensagens de alta throughput, a latência pode ser reduzida para o nível de milissegundos, apoiando o fluxo eficiente de eventos.

Otimizar o sistema de certificação e manter a conformidade com o método de certificação oferecido pela plataforma de integração convergente para melhorar a facilidade de uso do produto. Quando o cluster de plataforma de integração convergente expande a capacidade, os dados do líder de eventos, réplicas, Isr, são redistribuídos com um clique na interface Web. Para tarefas novas ou já construídas, sintonize com um clique através da interface Web, sem precisar de sintonizar com um clique através do complicado código da linha de comando. As informações básicas do evento e o progresso do consumo de cada consumidor no evento podem ser visualizadas com um clique na interface Web, com uma visão geral do evento.

Desenvolvimento de API em uma única parada

O sistema oferece capacidade de integração e desenvolvimento de APIs em uma única parada, abertura rápida de bancos de dados para interfaces Restful, acesso rápido a autorizações de certificação unificadas de APIs de sistemas de aplicativos de parceiros e suporte ao desenvolvimento e orquestração personalizados de APIs. Fornece capacidade de geração de APIs de codificação zero para tipos de bancos de dados como Oracle, SqlServer, Mysql, PostgreSQL, Dartmouth, vertica5 e outros, para concluir o desenvolvimento da API no processo de teste do assistente sem a necessidade de escrever SQL manualmente. A seleção de parâmetros de entrada e campos de saída durante o processo pode ser gerada automaticamente sem necessidade de configuração manual. As condições de associação e as instruções de consulta SQL complexas também suportam a configuração manual, e o processo de configuração também é testado de acordo com o assistente para satisfazer as características simples e fáceis de usar para o desenvolvimento da API. A diversidade de métodos de autenticação de interfaces de terceiros leva ao uso de APIs entre aplicativos, e a conexão de dados traz uma carga de trabalho de docking enorme. A capacidade de interface de terceiros é realizada através do encaminhamento do proxy do modelo de certificação da plataforma de integração de fusão e da interface para fornecer acesso unificado e gerenciamento unificado, aberto pela certificação unificada da plataforma de integração de fusão, o aplicativo superior só precisa acessar o método de certificação unificada da plataforma de integração de fusão para concluir o trabalho de acoplamento original e complexo, reduzindo drasticamente a carga de trabalho de acoplamento e a facilidade de uso. A API de função pode ser programada em cenários complexos por meio de scripts js, a API existente é flexível para programar novas capacidades de API através da API de função, através do bloqueio da API de função para a diferença da API de acesso, para que o pacote unificado da API abra para atender às necessidades da API no cenário.

Governança da API durante todo o ciclo de vida

Três tipos de registro de API são oferecidos para atender à diversidade do registro da API, testar o acesso às APIs desenvolvidas, ver se as APIs estão funcionando e corrigir as APIs anormais. Teste a interface normal através do gateway da API implantada para completar a preparação para a abertura externa da API. Os gateways de API suportam a abertura de APIs em redes e ajudam as empresas a colaborar rapidamente em redes. A função de autorização concede e recupera acesso às APIs e exclui APIs no final do ciclo de vida. A perspectiva funcional do produto fornece gerenciamento de APIs ao longo do ciclo de vida da API, incluindo registro, teste, implantação, autorização, edição e exclusão. No âmbito dos processos de negócios, a plataforma de integração convergente fornece acesso à API e capacidade de geração de bancos de dados na camada do sistema de aplicativos, a camada de processos de negócios fornece a capacidade de visualização de orquestração de serviços, a camada de experiência do consumidor fornece controle seguro de autorização, aplicativos, assinaturas e aprovações, fornecendo capacidade de gerenciamento, monitoramento e governança da API ao longo do ciclo de vida.

Gestão global de ativos empresariais

Fornece gerenciamento integrado de ativos de dados, interfaces de negócios e mensagens de eventos. Registre, teste e implante ativos empresariais, forneça recursos de importação e exportação de ativos integrados e suporta a exportação de ativos registrados para e a partir de arquivos. Os ativos empresariais são autorizados ao espaço de trabalho do aplicativo de forma solicitada, aprovada e certificada para completar a habilitação do aplicativo.

Integração de dados

1. Interface gráfica de operação

A integração de dados fornece uma operação de visualização de orquestração de todo o processo, com base na arquitetura BS compatível com vários dispositivos e acesso ao navegador, fornece extração de dados baseada em SWT, processamento de dados, ferramentas de carregamento de dados, os desenvolvedores podem facilmente realizar configurações de tarefas complexas através de drag and drop na interface gráfica, sem codificação, o pessoal empresarial pode facilmente controlar o fluxo de dados, o sistema fornece mais de 70 componentes de processamento de dados, lidar com vários processamentos responsáveis ​​de dados, reduzir a dificuldade de integração de dados e limiares de uso.

2. Fontes de dados enormes

Configure recursos comuns, como conexões de banco de dados, processos ETL, configurações relacionadas a clusters de dados grandes e outros, de uma só vez e várias vezes, suportando as seguintes fontes de dados:

Suporta leitura, análise e integração de arquivos semi-estruturados como Excel, CSV, XML, JSON e outros;

Suporta interfaces de banco de dados relacionais comuns, como DB2, SAP HANA, Oracle, SQLServer, MySQL, PostgreSQL, MongoDB, Redis, Datadream e outros bancos de dados;

Suporta interfaces de banco de dados MPP, como Teradata, Greenplum, Vertica, H3C DataEngine MPP, etc.

Suporte para Hadoop, adaptação para tipos de dados como HDFS, Hive, HBase, Kafka, ElasticSearch;

Suporta a extração de dados de arquivos FTP e SFTP;

Suporte para WebService, Restful e MQTT;

Suporta APIs padrão de conexão de banco de dados JDBC e ODBC, etc.

3. Fortalecimento do processamento de dados

Suporta sincronização em lote (offline), sincronização em tempo real, sincronização incremental e capacidade de migração de biblioteca completa. Modelo de processamento de dados baseado em fluxos de dados distribuídos para maximizar a capacidade de processamento de cada etapa; Suporta a execução paralela de várias instâncias. Oferece uma coleção de mais de setenta componentes de conversão de processamento de dados que suportam processamento de desempenho diversificado de dados e simplificam as operações manuais na integração de grandes volumes de dados.

4. Planejamento unificado de operações

O cronograma de tarefas suporta o cronograma de tarefas em várias dimensões de tempo (dias, horas, minutos). A extração incremental de dados é concluída em apenas alguns passos. Configuração simples, flexível e fácil de usar. Suporta mecanismos flexíveis e multiangulares de cronograma de tarefas modelo, incluindo cronograma em tempo real, cronograma, cronograma de ciclo de intervalo de tempo, etc. Através da otimização da integração do sistema, o gerenciamento de cronograma automatizado unificado All-in-One é finalmente alcançado.

5. Monitoramento operacional integral

O sistema fornece monitoramento de operações multidimensionais visuais, permitindo que a excelente facilidade de uso seja maximizada, fornecendo monitoramento de recursos para vários atuadores do ambiente operacional, incluindo ocupação da CPU, uso da memória, espaço em disco, etc., através do monitoramento unificado, o agendamento da tarefa pode ser distribuído racionalmente para melhorar a eficiência do processamento de dados. Ao mesmo tempo, quando as tarefas ocorrem erros e os atuadores são sobrecarregados por cenários de alto nível, a integração de dados suporta a notificação de alertas em tempo real ao usuário de forma pré-definida.

Mecanismo de tolerância anormal

A terminação anormal do servidor ou do cliente não afeta o funcionamento normal das partes não anormais. Por exemplo, após a terminação anormal do servidor, o executador continuará executando as tarefas emitidas como um contêiner de execução (cadeia de tarefas) e enviará informações como os resultados da execução ao servidor após o início do serviço.

Integração de mensagens

Mecanismo de transmissão de mensagens seguro e confiável

Compatível com as características nativas do Kafka, com todas as características de processamento de mensagens do Kafka nativo, suporte à transmissão segura de mensagens, controle de acesso à rede reforçado através da certificação Sasl, criptografia de armazenamento de mensagens e outras medidas, suporte a dados de mensagens altamente confiáveis, suporte à persistência de mensagens, mecanismo de armazenamento de múltiplas cópias.

2. Processamento de mensagens em tempo quase real de alto desempenho

A integração de mensagens serve como um link intermediário para o armazenamento de dados, oferecendo serviços de processamento de mensagens de alta throughput com latência reduzida a milissegundos. O cliente nativo do Kafka não fornece mecanismos para visualizar o conteúdo da mensagem do tópico, e a integração de mensagens fornece ao usuário uma página da Web que pode visualizar o corpo da mensagem em qualquer desvio em todas as partições de todos os tópicos em tempo real. A consulta de mensagens fornece principalmente a capacidade de consulta de mensagens em um cluster Kafka visualizado a nível de milissegundos, com suporte para filtragem por partição e tempo de produção.

Progresso do consumo

Para processos de consumo de tópicos com grandes quantidades de dados, os usuários podem ver o progresso do consumo de todas as partições específicas de tópicos consumidos por grupos de consumidores em tempo real através da página web fornecida pela integração de mensagens.

Redistribuição de tópicos

Quando os recursos do cluster Kafka usam recursos que já estão além da configuração do sistema, a escalabilidade dos recursos do cluster Kafka é necessária expandindo os nós Kafka. Os novos nós Kafka só estão envolvidos na criação de um novo tópico, e as partições em outros nós Broker anteriores não são automaticamente equilibradas e não podem atingir o efeito de carga. Quando o cluster Kafka é expandido, para aliviar a pressão de carga no nó Broker original, todas as partições do tópico são realocadas para todos os nós expandidos através da redistribuição de tópico integrada em mensagens para completar o equilíbrio de carga. A integração de mensagens gera automaticamente sugestões de redistribuição e também suporta ajustes manuais do usuário.

5. Monitoramento completo de indicadores de mensagens

A integração de mensagens fornece uma variedade de métricas de monitoramento para o cluster Kafka, incluindo a pilha de tópicos, o número de mensagens, a capacidade de mensagens, o número de falhas de solicitações de produção / consumo, o número de bytes recusados, o número de conversões de mensagens, o número de solicitações de produção / consumo e muito mais.

Integração de Serviços

API de geração de codificação zero

A plataforma oferece a publicação de registro de API guiada, serviço de geração de código zero, operação rápida e fácil de usar.

2. Publicação de interfaces em rede

Os gateways de API fornecidos pela plataforma permitem acessar interfaces de diferentes redes e suportam a abertura de APIs entre redes e sistemas, ajudando as empresas a colaborar rapidamente em várias redes.

3. Organização dos serviços

Organize as APIs conectadas em paralelo por meio de tela, fornecendo componentes filtrados e combinados para resolver cenários de negócios específicos.

Processamento de processo de programação: suporte para a sequência de execução de várias APIs, incluindo relações consecutivas, paralelas e processamento de dependências

Resolução de parâmetros de orquestração: analisa os retornos de várias APIs para obter os retornos da API anterior como entrada da API posterior ou saída de toda a API orquestrada

Controle de processo de orquestração: Determina a subsequente execução de ramificações de processo com base nos resultados retornados por uma API (os tipos que podem ser processados incluem: valores, strings, datas, matrizes).

Organizar combinações de resultados: combinar duas APIs de retorno de resultados (tipo Lista) de acordo com os valores de dois campos específicos

Seleção de resultados de orquestração: selecionar o valor de retorno da API orquestrada a partir de algumas APIs, pode ser selecionado entre componentes da API, componentes de fusão

Certificação Sul

A plataforma suporta o acesso a interfaces de terceiros com autenticação dinâmica, pode resolver rapidamente os problemas de autenticação através da configuração da interface, quando o usuário acessa a API, apenas precisa autenticar através do gateway da API da plataforma, sem perceber a autenticação da interface de terceiros.

5. Gestão de Container

A plataforma adota a implantação de cluster de contêineres, a orquestração flexível de contêineres e a implantação de construção automatizada, melhorando a eficiência de desenvolvimento e manutenção e a utilização de recursos, fornecendo serviços diversificados e abrangentes como escalabilidade flexível, isolamento de recursos, recuperação de capacidade de desastres, equilíbrio de carga e outros, ajudando as empresas a construir mecanismos de alta disponibilidade e segurança para serviços em cenários de negócios complexos.