Plateforme d'intégration H3C Fusion

La plate - forme sanoasis de Xinhua est une plate - forme numérique basée sur le concept de briser les « silos d'information» pour éliminer la « cheminée de données», aidant les entreprises à utiliser leurs données pour tirer le meilleur parti de leurs données.

Oasis Converged Integration Platform pour tous les types de systèmes d'entreprise, fournit des API, des messages, l'intégration de données, masque les différences de système sous - jacent pour les applications d'entreprise, fournit un support de service unifié, aide les développeurs à développer rapidement la capacité d'intégrer les systèmes existants, l'intégration de systèmes Pour répondre aux besoins de connectivité riches dans le processus de numérisation d'une plate - forme ipaas distribuée résiliente.

La plate - forme d'intégration Oasis Converged comprend des capacités telles que l'intégration de messages, l'intégration de services, l'intégration de données, la gestion des ressources et d'autres, via la connexion à la plate - forme d'exploitation de données, fournissant des modèles de données standard pour former divers modèles de données d'entreprise. Avec le développement d'actifs, formez des modèles pour les API couramment utilisées, mettez en œuvre le multiplexage et accélérez la fourniture de services externes. En outre, pour les scripts d'orchestration de données couramment utilisés, l'encapsulation des capacités communes, la mise en œuvre du multiplexage des capacités et d'éviter le développement répétitif. L'ouverture vers l'extérieur fournit des interfaces standardisées et des modèles de services tels que la reconnaissance faciale, la synthèse vocale, etc. en tant que sorties de capacités standard, éliminant ainsi la nécessité pour les utilisateurs d'effectuer des opérations de configuration sur une plate - forme d'intégration convergente. Standardisation du modèle de service, permettant un multiplexage rapide et un développement externe du modèle de service.

Intégration massive de données hétérogènes

La complexité et la diversité des systèmes d'affaires de l'entreprise, d'une part, apportent la diversité des types de données, telles que les données de base de données relationnelle traditionnelle, les messages, API、 Les fichiers, etc., posent des défis quant à la complétude fonctionnelle de l'intégration des données. D'autre part, avec le développement de l'entreprise, le volume de données a également connu une croissance explosive, posant également un défi élevé à l'efficacité de l'intégration des données. Plate - forme d'intégration Oasis fusion prenant en charge plus de 30 types de sources de données, fournissant des données, des messages, API、 Diverses capacités d'intégration telles que les protocoles IOT, y compris l'intégration de données pour les scénarios par lots et en temps réel et des services d'intégration efficaces et sécurisés pour les applications, permettent une suite de plates - formes d'intégration pour compléter l'intégration de données hétérogènes massives.

Files d'attente de messages distribuées pilotées par événements

Le dispositif IOT capture des événements pour générer des messages d'événements, les messages d'événements fournissent une file d'attente de messages distribuée unifiée en temps réel via la plate - forme d'intégration convergente, le système de traitement intelligent des événements acquiert les messages d'événements correspondants de consommation via la requête et l'abonnement aux événements, les événements traités ou les messages de classe de cas formés par le flux, la livraison en temps réel intégrée via la plate - forme d'intégration convergente de messages vers le bas, l'escalade et la diffusion utilisent différents canaux de données, le dispositif IOT pilote pour effectuer le traitement correspondant, comme l'interrupteur du déclencheur, l'interrupteur du dispositif d'éclairage intelligent et d Le processus d'entraînement en courant d'un événement utilise un mécanisme d'accès de message unifié, un canal de message normalisé, réduisant les coûts d'amarrage du système résultant de l'utilisation de différents composants de message.

Centre d'écoulement d'événements sûr et efficace

La plate - forme d'intégration Oasis fusion fournit un système de pipeline de messagerie quasi - temps réel à haut débit et durable, compatible avec les fonctionnalités natives de traitement des messages Kafka et prenant en charge la transmission sécurisée des messages. La publication / l'abonnement de messages est certifié sasl, le cryptage SSL, les groupes de sécurité, etc. renforcer le contrôle d'accès au réseau, fournir le stockage d'événements, les requêtes d'événements, les abonnements d'événements, la publication d'événements, la surveillance d'événements et d'autres canaux d'accès aux événements efficaces du côté de la production et du traitement des événements grand public, fournir des services de traitement de messages à haut débit, la latence peut être réduite à des niveaux millisecondes, soutenir un flux d'événements efficace.

Optimisez le système de certification et la plate - forme d'intégration convergente pour aligner les méthodes de certification externes, améliorant ainsi la facilité d'utilisation des produits. Lorsque la capacité de mise à l'échelle du cluster de la plate - forme d'intégration convergente est redistribuée en un clic sur l'interface Web pour les données leader, Replicas, ISR de l'événement. Pour les tâches nouvelles ou construites, Ajustez - les en un clic via l'interface Web sans devoir passer par un code de ligne de commande encombrant. Les informations de base sur l'événement et la progression de la consommation de chaque consommateur pour l'événement peuvent être consultées en un clic sur l'interface Web et le profil de l'événement est connu en un coup d'œil.

Développement d'api à guichet unique

Le système offre des capacités d'intégration et de développement d'api à guichet unique, une base de données ouverte rapide pour l'interface restful, un accès rapide à l'autorisation de certification unifiée des API de système d'application partenaire et un support pour le développement et l'orchestration personnalisés d'api. Fournit une capacité de génération d'api à codage nul pour les types de bases de données Oracle, SQLServer, MySQL, PostgreSQL, daremont, vertica5, etc., sans écrire manuellement SQL pour terminer le développement de l'API sous le processus d'essai de l'assistant. La sélection des paramètres d'entrée et des champs de sortie pendant le processus peut être générée automatiquement sans configuration manuelle. Les conditions associées et les instructions de requête SQL complexes prennent également en charge la configuration manuelle, et le processus de configuration est testé en suivant l'assistant pour répondre aux fonctionnalités simples et simples de développement de l'API. La diversité des méthodes d'authentification des interfaces tierces impose une charge de travail considérable pour l'utilisation des API inter - applications et la connexion des données. Grâce au modèle d'authentification de plate - forme d'intégration convergente et au transfert d'agent de l'interface pour atteindre la capacité d'interface tierce pour fournir un accès unifié et une gestion unifiée, grâce à l'ouverture d'authentification unifiée de la plate - forme d'intégration convergente, les applications de couche supérieure ont simplement besoin d'accéder à La méthode d'authentification unifiée de la plate - forme d'intégration convergente pour effectuer le travail d'amarrage complexe d'origine, réduisant considérablement la charge de travail d'amarrage et la L'API de fonction peut implémenter l'orchestration d'api dans des scénarios complexes en écrivant des scripts JS, l'API existante par l'intermédiaire de l'API de fonction flexible orchestrant de nouvelles capacités d'API, par l'intermédiaire de l'API de fonction masquant les différences d'api côté accès, de sorte que l'encapsulation unifiée d'API est ouverte pour répondre aux besoins d'api dans les scénarios.

Gouvernance des API tout au long du cycle de vie

Fournir trois types d'enregistrement d'API, répondre à la diversité du côté de l'enregistrement d'API, effectuer des visites de test sur les API développées, voir si les API fonctionnent, effectuer des corrections correspondantes pour les API anormales. Test d'une interface normale via la passerelle API déployée, complète la préparation de l'API à l'ouverture vers l'extérieur. API Gateway prend en charge l'ouverture d'api sur tous les réseaux, aidant les entreprises à accélérer la collaboration entre les réseaux. La fonction d'autorisation accorde et recycle l'accès aux API, et les API de fin de vie sont supprimées. Angle de fonctionnalité du produit, offrant une gestion complète des API pour l'enregistrement, le test, le déploiement, l'autorisation, l'édition, la suppression, etc. des API. Du point de vue des processus métier, la plate - forme d'intégration convergente fournit l'accès aux API et la capacité de génération des bases de données de la couche système d'application, la couche processus métier fournit la capacité d'Orchestration visuelle des services et la couche expérience client fournit des capacités de contrôle sécurisées des autorisations, des demandes, des abonnements et des approbations, offrant des capacités de gestion, de surveillance et de gouvernance des API tout au long de la vie.

Gestion d'actifs d'entreprise à l'échelle du domaine

Fournit une gestion intégrée des actifs de données, des interfaces métier et des messages d'événements. Enregistrez, testez, déployez des actifs d'entreprise, Fournissez des fonctionnalités d'importation et d'exportation d'actifs intégrés, soutenez l'exportation et l'importation d'actifs enregistrés à partir de fichiers. Les actifs de l'entreprise sont autorisés à l'espace de travail de l'application par application, approbation et certification, complétant l'habilitation de l'application.

Intégration de données

1. Interface de fonctionnement graphique

L'intégration de données fournit des opérations visuelles d'orchestration de processus complets, est compatible avec un large éventail d'appareils et d'accès aux navigateurs basés sur l'architecture BS, fournit des outils SWT d'extraction de données, de traitement de données et de chargement de données, les développeurs n'ont besoin que d'une interface graphique pour effectuer facilement des configurations de tâches complexes sans codage, le personnel d'entreprise peut facilement contrôler le flux de données, le système fournit plus de 70 composants de traitement de données, gère un large éventail de traitements de données responsables, réduit la difficulté d'intégration de données et les seuils d'utilisation.

2. Sources massives de données

Configurez une fois et utilisez plusieurs fois des ressources fréquemment utilisées telles que les connexions de base de données, les procédures ETL, les éléments de configuration liés aux clusters de données volumineux, etc. les sources de données prises en charge sont les suivantes:

Prend en charge la lecture, l'analyse et l'intégration de fichiers semi - structurés tels que Excel, CSV, XML, json, etc.;

Prise en charge des interfaces de base de données relationnelles communes telles que DB2, SAP Hana, Oracle, SQLServer, MySQL, PostgreSQL, mongodb, redis, daremont, etc.

Prise en charge des interfaces de base de données MPP telles que teradata, greenplum, vertica, H3C DataEngine MPP, etc.;

Prise en charge de Hadoop pour l'adaptation de données de type hdfs, Hive, hbase, Kafka, elasticsearch, etc.;

Prise en charge de la décimation de données de fichiers FTP, SFTP;

Support Webservice, restful, mqtt;

Prise en charge des API JDBC et ODBC Database Connectivity standard, etc.

3. Traitement renforcé des données

Prend en charge la synchronisation par lots (hors ligne), la synchronisation en temps réel, la synchronisation incrémentielle, la capacité de migration de bibliothèque complète. Modèle de traitement des données basé sur un flux de données distribué, maximisant la puissance de traitement des différentes étapes; Prise en charge simultanée de l'exécution parallèle Multi - instances. Fournit une collection de plus de soixante - dix composants de transformation de traitement de données qui prennent en charge le traitement des performances diversifiées des données et simplifient les opérations manuelles dans l'intégration de données à grand volume.

4. Planification unifiée des opérations

La planification des tâches prend en charge la planification de la synchronisation des tâches dans plusieurs dimensions temporelles (jours, heures, minutes), ne nécessite que quelques étapes simples pour effectuer la décimation incrémentielle des données, est simple à configurer, flexible et facile à utiliser, prend en charge des mécanismes de planification des tâches flexibles et multi - angles, y compris la planification en temps réel, la planification de la synchronisation, la planification cyclique des intervalles de temps, etc., grâce à l'optimisation de la consolidation du système pour une gestion unifiée et automatisée de la planification All - in - one.

5. Surveillance opérationnelle complète

Le système fournit une surveillance visuelle Multi - dimensionnelle de l'exécution des tâches, ce qui permet une excellente facilité d'utilisation pour une généralisation maximale, fournit une surveillance des ressources pour plusieurs actionneurs de l'environnement d'exploitation, y compris l'occupation du CPU, l'utilisation de la mémoire, l'espace disque, etc., avec une surveillance unifiée qui peut rationnellement allouer la planification des tâches et améliorer l'efficacité du traitement des données. Dans le même temps, le support d'intégration de données informe l'utilisateur des informations d'alerte en temps réel par des moyens prédéfinis lorsqu'une tâche présente une erreur et que l'actionneur est surchargé de scénarios élevés.

6. Mécanisme de tolérance anormale

Qu'il s'agisse d'une terminaison anormale du serveur ou du client, cela n'affecte pas le bon fonctionnement de la partie non anormale. Par exemple, après la fin d'une exception côté service, l'exécution de l'exécuteur en tant que conteneur de tâche (chaîne de tâches) continue à exécuter la tâche sortante et, une fois le service démarré, renvoie des informations telles que les résultats de l'exécution au côté service.

Intégration de messages

1. Mécanisme de transmission de message sûr et fiable

Compatible avec les fonctionnalités natives de Kafka, avec toutes les fonctionnalités de traitement des messages natives de Kafka, prend en charge la transmission sécurisée des messages, l'authentification sasl, le chiffrement du stockage des messages et d'autres mesures pour renforcer le contrôle d'accès au réseau, prend en charge les données de message de haute fiabilité, prend en charge la persistance des messages, le mécanisme de stockage de copies multiples.

2. Traitement de message quasi - temps réel de haute performance

L'intégration de messages agit comme un lien intermédiaire dans le stockage de données, fournissant des services de traitement de messages à haut débit avec une latence pouvant être réduite à des niveaux de millisecondes Ms. Le client natif Kafka ne fournit pas de mécanisme pour afficher le contenu des messages Topic, et l'ensemble de messages est devenu une page Web pour les utilisateurs qui peuvent voir le corps du message en temps réel avec un décalage arbitraire de toutes les partitions dans tous les topic. Message Query fournit principalement des capacités de requête de message dans un Cluster Kafka visuel de niveau milliseconde, prenant en charge le filtrage par partitionnement et temps de production.

3. Progression de la consommation

Pour les processus de consommation de topics avec des volumes de données plus importants, les utilisateurs peuvent visualiser en temps réel la progression de la consommation de partitions spécifiques de tous les topics consommés par un groupe de consommateurs via une page Web fournie par l'intégration de messages.

4 Topic redistribution

Lorsque les ressources du cluster Kafka utilisent des ressources qui ont dépassé la configuration du système, l'extension des ressources du cluster Kafka doit être réalisée en étendant les nœuds Kafka. Les nouveaux nœuds Kafka ne seront impliqués que lors de la création d'un nouveau topic, et les partitions sur d'autres nœuds broker ne seront pas automatiquement égalisées et n'auront pas d'effet de charge. Lorsque le cluster Kafka est étendu, afin de réduire la pression de charge sur le nœud broker d'origine, l'équilibrage de charge est effectué en redistribuant toutes les partitions de topic à tous les nœuds après l'extension via la fonctionnalité de redistribution Topic intégrée par message. L'intégration de messages peut générer automatiquement des suggestions de redistribution, tout en prenant également en charge l'ajustement manuel par l'utilisateur.

5. Surveillance complète des indicateurs de message

L'intégration de messages fournit divers indicateurs de surveillance pour le cluster Kafka, notamment le volume d'empilement Topic, le nombre de messages, la capacité des messages, le nombre d'échecs de demandes de production / consommation, le nombre d'octets rejetés, le nombre de conversions de messages, le nombre de demandes de production / consommation, etc.

Intégration de services

1. API de génération de codage zéro

La plate - forme fournit une publication d'enregistrement d'API de type assistant, un service de génération de codage zéro, une opération facile et rapide et une grande facilité d'utilisation.

2. Publication d'interface inter - réseau

Les passerelles API fournies par la plate - forme peuvent accéder aux interfaces de différents réseaux, ce qui prend en charge l'ouverture d'api entre réseaux et systèmes, aidant les entreprises à réaliser rapidement une collaboration Multi - réseaux.

3. Organisation des services

L'orchestration en parallèle Torra - pull des API déjà accessibles via Canvas fournit des composants de filtrage, des composants de fusion pour résoudre des scénarios métier spécifiques.

Orchestration du traitement des processus: prend en charge l'ordre d'exécution de plusieurs API, y compris les relations séquentielles, juxtaposées, le traitement des dépendances

Analyse des paramètres d'Orchestration: analyse des résultats de retour de plusieurs API pour obtenir les résultats de retour des API précédentes en entrée des API suivantes ou en sortie de l'API orchestrée dans son ensemble

Orchestration du contrôle des processus: décider de l'exécution ultérieure d'une branche de processus en fonction des résultats retournés par une API (types pouvant être traités: valeurs numériques, chaînes, dates, tableaux).

Orchestration des combinaisons de résultats: combine les résultats retournés par les deux API (type List) en fonction des valeurs de deux champs

Sélection des résultats de l'orchestration: Sélectionnez la valeur de retour de l'API orchestrée à partir de certaines API, vous pouvez choisir parmi les composants de l'API, les composants fusionnés

4. Certification orientée Sud

La plate - forme prend en charge l'accès à des interfaces tierces avec authentification dynamique, peut être configurée par l'interface de manière à résoudre rapidement les problèmes d'authentification, lorsque l'utilisateur accède à l'API, il suffit de passer par l'authentification de la passerelle API de la plate - forme, aucune perception de l'authentification de L'interface tierce.

5. Gestion des opérations et de la maintenance conteneurisée

La plate - forme utilise le déploiement de Clusters conteneurisés, l'orchestration flexible des conteneurs, le déploiement automatisé de la construction, l'amélioration de l'efficacité des opérations de développement et d'entretien et de l'utilisation des ressources, la fourniture d'une gamme diversifiée et complète de services tels que l'évolutivité élastique, l'isolation des ressources, La résilience aux catastrophes, l'équilibrage de charge, etc., pour aider les entreprises à créer des mécanismes hautement disponibles et contrôlables en toute sécurité dans des scénarios commerciaux complexes.