Plataforma de integración de integración H3C

La plataforma Xinhua sanoasis es una plataforma de base digital que rompe el concepto de "isla de información" para eliminar la "chimenea de datos" y ayuda a las empresas del Grupo a usar los datos para maximizar el valor de los datos.

La Plataforma de integración Oasis proporciona api, integración de mensajes y datos para varios sistemas de negocios, protege las diferencias de los sistemas subyacentes de las aplicaciones de negocios, proporciona soporte de servicio unificado, ayuda a los desarrolladores a desarrollar e integrar rápidamente la capacidad de los sistemas existentes e integrar sistemas para satisfacer las ricas necesidades de conexión en el proceso digital.

La Plataforma de integración de Oasis incluye la integración de mensajes, la integración de servicios, la integración de datos, la gestión de recursos y otras capacidades. a través de la conexión con la Plataforma de operación de datos, proporciona modelos de datos estándar y forma varios modelos de datos empresariales. Con la ayuda del desarrollo de activos, se forman plantillas para API comunes, se realiza la reutilización y se acelera la prestación de servicios externos. Además, los guiones de programación de datos comunes, la encapsulación de capacidades generales, la reutilización de capacidades y la evitación de desarrollos duplicados. La apertura al mundo exterior proporciona interfaces estandarizadas y modelos de servicio, como reconocimiento facial, síntesis de voz, etc., como salida de capacidad estándar, sin necesidad de que los usuarios realicen operaciones de configuración en la Plataforma de integración de fusión. Estandarizar el modelo de servicio para lograr una rápida reutilización y desarrollo externo del modelo de servicio.

Integración masiva de datos heterogéneos

La complejidad y diversidad de los sistemas empresariales empresariales, por un lado, trae consigo la diversidad de tipos de datos, como los datos de las bases de datos relacionales tradicionales, los mensajes, API、 Los archivos, etc., plantean desafíos a la integridad funcional de la integración de datos. Por otro lado, con el desarrollo del negocio, el volumen de datos también muestra un crecimiento explosivo, lo que también plantea un alto desafío para la eficiencia de la integración de datos. La plataforma integrada de integración Oasis admite más de 30 tipos de fuentes de datos, proporciona datos, mensajes, API、 Una variedad de capacidades de integración, como el Protocolo iot, incluyen la integración de datos para escenarios por lotes y en tiempo real y servicios integrados eficientes y seguros para aplicaciones, logrando un conjunto de plataformas integradas para completar la integración de datos heterogéneos masivos.

Cola de mensajes distribuida impulsada por eventos

El equipo de IOT captura los mensajes de eventos para generar mensajes de eventos, los mensajes de eventos proporcionan una transmisión unificada en tiempo real de colas de mensajes distribuidas a través de la Plataforma de integración de integración, el sistema inteligente de procesamiento de eventos obtiene los mensajes de eventos correspondientes al consumo a través de consultas y suscripciones de eventos, los mensajes de casos formados por eventos procesados o flujos, y los mensajes se transmiten en tiempo real a través de la Plataforma de integración de mensajes de la Plataforma de integración de integración, los informes y las emisiones utilizan diferentes canales de datos para conducir el equipo de IOT para hacer el procesamiento correspondiente, como el interruptor de la puerta, el interruptor del equipo de iluminación inteligente y otras acciones correspondientes. El proceso impulsado por la circulación de eventos utiliza un mecanismo unificado de acceso a mensajes, canales de mensajes estandarizados y reduce los costos de acoplamiento del sistema debido al uso de diferentes componentes de mensajes.

Un centro de circulación de eventos seguro y eficiente

La plataforma integrada de fusión Oasis proporciona un sistema de tuberías de mensajes cuasi - en tiempo real persistente y de alto rendimiento, compatible con las características nativas de procesamiento de mensajes Kafka y compatible con la transmisión segura de mensajes. La publicación / suscripción de mensajes fortalece el control de acceso a la red a través de la autenticación sasl, el cifrado ssl, los grupos de seguridad, etc., proporcionando canales de acceso eficientes a eventos en el lado de la generación y el procesamiento de consumo de eventos, como el almacenamiento de eventos, la consulta de eventos, la suscripción de eventos, la publicación de eventos, el monitoreo de eventos, y proporcionando servicios de procesamiento de mensajes de alto rendimiento, el retraso se puede reducir al nivel de milisegundos, apoyando el flujo eficiente de eventos.

Optimizar el sistema de certificación, ser coherente con los métodos de certificación proporcionados por la plataforma integrada integrada integrada integrada y mejorar la facilidad de uso del producto. Cuando el clúster de la plataforma integrada de fusión se expande, para el líder del evento, replicas, datos isr, se redistribuye con un solo clic en la interfaz Web. Para las tareas nuevas o construidas, se ajusta con un solo clic a través de la interfaz web, sin necesidad de ajustar con un solo clic a través de un engorroso Código de línea de órdenes. Se puede ver la información básica del evento con un solo clic en la interfaz web y el progreso del consumo del evento por parte de cada consumidor, y la visión general del evento se conoce por completo.

Desarrollo de API de ventanilla única

El sistema proporciona una capacidad de integración y desarrollo API de ventanilla única, la base de datos abierta rápidamente es una interfaz restful, el acceso rápido a la autenticación y autorización unificadas de la API del sistema de aplicaciones de socios, y admite el desarrollo y la programación personalizados de la api. Proporciona la capacidad de generación de APIs de codificación cero de tipos de base de datos como oracle, sqlserver, mysql, postgreql, dameng y vertica5, y puede completar el desarrollo de APIS bajo el proceso probado por el asistente sin escribir manualmente sql. La selección de parámetros de entrada y campos de salida durante el proceso se puede generar automáticamente sin configuración manual. Las condiciones de asociación y las complejas sentencias de consulta SQL también admiten la configuración manual, y el proceso de configuración también se prueba de acuerdo con el asistente para satisfacer las características fáciles de usar y sencillas del desarrollo de la api. La diversidad de métodos de autenticación de interfaces de terceros ha traído una gran carga de trabajo de acoplamiento al uso de API entre aplicaciones y la conexión de datos. A través de la integración de la plantilla de autenticación de la plataforma integrada y el reenvío del agente de la interfaz, se realiza la capacidad de interfaz de terceros para proporcionar acceso unificado y gestión unificada. a través de la apertura unificada de autenticación de la plataforma integrada integrada integrada integrada, las aplicaciones superiores solo necesitan acceder al método de autenticación unificada de La plataforma integrada integrada integrada integrada integrada para completar el complejo trabajo de acoplamiento original, reduciendo en gran medida la carga de trabajo de acoplamiento y la facilidad de uso. La API de funciones puede realizar la coreografía API en escenarios complejos escribiendo guiones js. las API existentes organizan con flexibilidad nuevas capacidades API a través de la API de funciones, y bloquean las diferencias de la API del lado de acceso a través de la API de funciones, de modo que la apertura unificada de la encapsulación de la API satisface las necesidades de la API en escenarios.

Gobernanza de la API durante todo el ciclo de vida

Ofrece tres tipos de registro de API para satisfacer la diversidad del lado de registro de api, realizar visitas de prueba a las API desarrolladas, ver si la API es normal y reparar las API anormales en consecuencia. Probar la interfaz normal a través de la pasarela API desplegada para completar la preparación de la apertura de la API al mundo exterior. API Gateway admite la apertura de API entre redes y ayuda a las empresas a lograr rápidamente la colaboración entre redes. La función de autorización otorga y recupera los derechos de acceso a la api, y elimina la API al final del ciclo de vida. Desde el punto de vista funcional del producto, proporciona la gestión API de todo el ciclo de vida de la api, como registro, prueba, despliegue, autorización, edición y eliminación. Desde el punto de vista de los procesos empresariales, la plataforma integrada integrada proporciona la capacidad de acceso API y generación de bases de datos a nivel de sistema de aplicaciones, la capacidad de Programación visual de servicios a nivel de procesos empresariales, la capacidad de control seguro de autorización, solicitud, suscripción y aprobación a nivel de experiencia de consumo, y la capacidad de gestión, monitoreo y gobernanza API a lo largo de toda la vida.

Gestión de activos empresariales globales

Proporciona la gestión integrada de activos de datos, interfaces de negocio y mensajes de eventos. Registrar, probar y desplegar activos comerciales, proporcionar funciones de importación y exportación de activos integrados, apoyar la exportación de activos registrados a archivos e importar de archivos. Los activos comerciales se autorizan al espacio de trabajo de la aplicación de acuerdo con la solicitud, aprobación y certificación para completar el empoderamiento de la Aplicación.

Integración de datos

1. interfaz de operación gráfica

La integración de datos proporciona operaciones de visualización de todo el proceso, compatible con una variedad de dispositivos y accesos al navegador basados en la arquitectura bs, proporciona herramientas de extracción de datos, procesamiento de datos y carga de datos basadas en swt, los desarrolladores solo necesitan realizar fácilmente una configuración de tarea compleja a través de un arrastrar y aflojar en la interfaz gráfica, sin ninguna codificación, el personal de negocios puede controlar fácilmente el flujo de datos, el sistema proporciona más de 70 componentes de procesamiento de datos, para hacer frente a una variedad de procesamiento de datos responsable, reducir la dificultad de integración de datos y el umbral de uso.

2. fuentes de datos masivas

Los recursos comunes, como la conexión a la base de datos, el proceso ETL y los elementos de configuración relacionados con el clúster de Big data, se configuran de una sola vez y se utilizan muchas veces en muchos lugares. las fuentes de datos de soporte son las siguientes:

Soporte para leer, analizar y integrar archivos semiestructurados como microsoft, csv, xml, json, etc.;

Soporte de interfaces de bases de datos relacionales generales, como db2, SAP hana, oracle, servidor qlserver, mysql, postgreql, mongodb, redis, dameng y otras bases de datos;

Soporte para la interfaz de base de datos mpp, como terradata, greenplum, vertica, H3C data Engine mpp, etc.;

Soporte hadoop para adaptarse a tipos de datos como hdfs, hive, hbase, Kafka y elasticsearch;

Soporte para la extracción de datos de archivos FTP y sftp;

Soporte para webservice, restful, mqt;

Soporte para jdbc y Odbc Database Connection Standard api, etc.

3. fortalecimiento del procesamiento de datos

Admite sincronización por lotes (fuera de línea), sincronización en tiempo real, sincronización incremental y capacidad de migración de biblioteca completa. El modelo de procesamiento de datos basado en el flujo de datos distribuido maximiza la capacidad de procesamiento de cada paso; Al mismo tiempo, admite la ejecución paralela de múltiples instancias. Proporciona una colección de más de 70 tipos de componentes de conversión de procesamiento de datos, admite el procesamiento de rendimiento diversificado de datos y simplifica las operaciones manuales en la integración de datos a gran escala.

4. despacho unificado de Operaciones

La programación de trabajos admite la programación de horarios de tareas multidimensionales (días, horas, minutos), que puede completar la extracción incremental de datos en solo unos pocos pasos simples, la configuración es simple, flexible y fácil de usar, y admite mecanismos de programación de trabajos modelo flexibles y multiángulos, incluyendo la programación en tiempo real, la programación de horarios, la programación circular de intervalos de tiempo, etc. a través de la integración y optimización del sistema, finalmente se realiza la gestión unificada y automatizada de la programación de todo - in - one.

5. monitoreo integral de Operaciones

El sistema proporciona un monitoreo visual de la operación de trabajo multidimensional, lo que permite maximizar la excelente facilidad de uso, proporcionando el monitoreo de recursos de múltiples ejecutores en el entorno de operación, incluyendo ocupación de cpu, uso de memoria, espacio de disco, etc. a través del monitoreo unificado, se puede asignar racionalmente la programación de tareas y mejorar la eficiencia del procesamiento de datos. Al mismo tiempo, cuando se produce un error en la tarea y el ejecutor está sobrecargado, el soporte de integración de datos informa al usuario de la información de alarma en tiempo real de una manera predefinida.

6. mecanismos de tolerancia anormal

Ni el lado del servicio ni la terminación anormal del cliente afectan el funcionamiento normal de la parte no Anormal. Por ejemplo, después de la terminación anormal del lado del servicio, el ejecutor, como contenedor de ejecución de trabajo (cadena de tareas), continuará realizando los trabajos emitidos y, una vez iniciado el servicio, retroalimentará los resultados de la ejecución y otra información al lado del servicio.

Integración de mensajes

1. mecanismo de transmisión de mensajes seguro y confiable

Compatible con las características nativas de kafka, con todas las características nativas de procesamiento de mensajes de kafka, soporte para transmisión segura de mensajes, a través de la autenticación sasl, cifrado de almacenamiento de mensajes y otras medidas para fortalecer el control de acceso a la red, soporte para datos de mensajes altamente confiables, soporte para persistencia de mensajes, mecanismo de almacenamiento de múltiples copias.

2. procesamiento de mensajes cuasi - en tiempo real de alto rendimiento

La integración de mensajes, como enlace intermedio del almacenamiento de datos, proporciona servicios de procesamiento de mensajes de alto rendimiento, y la latencia se puede reducir al nivel de milisegundos ms. El cliente nativo de Kafka no proporciona un mecanismo para ver el contenido de los mensajes de temas, y el conjunto de mensajes se convierte en una página web proporcionada por el usuario, que puede ver cualquier desplazamiento del texto de los mensajes en todas las particiones de todos los temas en tiempo real. La consulta de mensajes proporciona principalmente la capacidad de consulta de mensajes en el clúster Kafka en milisegundos y visualización, y admite el filtrado de acuerdo con la División y el tiempo de producción.

3. progreso del consumo

Para el proceso de consumo de temas con una gran cantidad de datos, los usuarios pueden ver en tiempo real el progreso del consumo de todas las particiones específicas de temas consumidos por el Grupo de consumidores a través de la página web proporcionada por la integración de mensajes.

4. redistribución de temas

Cuando los recursos del clúster Kafka utilizan recursos que han superado la asignación del sistema, es necesario lograr la expansión de los recursos del clúster Kafka mediante la expansión de los nodos kafka. Los nuevos nodos kafka, que solo participan en el trabajo cuando se crea un nuevo tema, no se equilibran automáticamente para las divisiones en otros nodos de broker anteriores y no pueden lograr el efecto de carga. Cuando el clúster Kafka se expande, para reducir la presión de carga del nodo broker original, todas las divisiones del tema se redistribuyen a todos los nodos después de la expansión a través de la función de redistribución de temas integrada en mensajes para completar el equilibrio de carga. La integración de mensajes puede generar automáticamente recomendaciones de redistribución, pero también admite ajustes manuales por parte de los usuarios.

5. monitoreo integral de indicadores de mensajes

La integración de mensajes proporciona varios indicadores de monitoreo del clúster kafka, incluyendo acumulación de temas, número de mensajes, capacidad de mensajes, número de solicitudes fallidas de producción / consumo, número de bytes rechazados, número de conversiones de mensajes, número de solicitudes de producción / consumo, etc.

Integración de servicios

1. API de generación de código cero

La plataforma ofrece un servicio de registro y publicación de API guiada, generación de código cero, operación conveniente, rápida y fácil de usar.

2. publicación de la interfaz entre redes

Las pasarelas API proporcionadas por la plataforma pueden acceder a las interfaces de diferentes redes, apoyar la apertura API entre redes y sistemas, y ayudar a las empresas a lograr rápidamente la colaboración multired.

3. Organización de los servicios

La API a la que se ha accedido se organiza a través de lienzos, proporcionando componentes de filtrado y componentes de fusión para resolver escenarios de negocio específicos.

Procesamiento del proceso de programación: admite el procesamiento de la Dependencia en el orden de ejecución de múltiples api, incluidas las relaciones de secuencia y yuxtaposición.

Análisis de parámetros de coreografía: analizar los resultados de retorno de varias API para lograr los resultados de retorno de la API anterior como entrada de la API posterior o salida de toda la API coreografiada

Control del proceso de coreografía: determina la rama del proceso de ejecución posterior en función de los resultados de retorno de una API (los tipos que se pueden procesar incluyen: valores, cadenas, fechas, matrices).

Organizar la combinación de resultados: combinar los resultados de retorno de dos API (tipo de lista) de acuerdo con los valores de uno o dos Campos

Selección de resultados de coreografía: selecciona el valor de retorno de la API coreografiada de algunas api, que se puede seleccionar entre los componentes de la api, los componentes de fusión

4. certificación hacia el Sur

La plataforma admite el acceso a interfaces de terceros con autenticación dinámica, que pueden resolver rápidamente los problemas de autenticación a través de la configuración de la interfaz. cuando los usuarios acceden a la api, solo necesitan autenticarse a través de la pasarela API de la Plataforma y no tienen percepción de la autenticación de interfaces de terceros.

5. gestión de operaciones y mantenimiento de contenedores

La plataforma adopta el despliegue de clústeres de contenedores, la programación flexible de contenedores y el despliegue automatizado de construcción, lo que mejora la eficiencia del desarrollo, operación y mantenimiento y la tasa de utilización de recursos, proporciona servicios diversificados e integrales, como flexibilidad y expansión, aislamiento de recursos, recuperación en casos de desastre y equilibrio de carga, y ayuda a las empresas a construir mecanismos de alta disponibilidad de servicios y seguridad y control en escenarios empresariales complejos.