Ingreso de Processing Data
Resumen
Los módulos ipf-processing-data-ingress se utilizan en aplicaciones que necesitan consumir IPF Processing Data, por ejemplo, ODS.
Transporte
El egress de ipf-processing-data envía sobres de IPF Processing Data por kafka o http, y existen componentes de ingress equivalentes para consumir estos datos.
Kafka
<dependency>
<groupId>com.iconsolutions.ipf.core.processingdata</groupId>
<artifactId>ipf-processing-data-ingress-kafka</artifactId>
</dependency>| Clave de configuración | Valor por defecto | Descripción |
|---|---|---|
|
|
Habilita o deshabilita el ingress por kafka. Cualquier valor distinto de |
|
|
El topic desde el que consumir sobres de IPF Processing Data. |
|
Los topics desde los que consumir sobres de IPF Processing Data, por ejemplo |
El ingress por kafka utiliza un conector receptor de kafka; puede encontrar más configuración bajo la clave ipf.processing-data.ingress.kafka.consumer.* en Connector Configuration o Kafka Quickstart.
Métricas
Se informarán las siguientes métricas para el ingress de kafka:
-
ipf_processing_data_ingest_latency, registra la duración entre el momento en que se han creado los Process objects (domain event, system event, message log…), MDS objects, PDS objects y Custom objects y el momento en que han sido procesados correctamente por el consumidor de Ingress; las duraciones serán sensibles a la desviación horaria entre servidores, por lo que deben considerarse estimaciones únicamente -
ipf_processing_data_ingress_batch_receive_size, registra el tamaño de cada lote de DataEnvelope recibido por su bean de springBatchedIpfProcessingDataHandler. Consulte la guía para consumir processing data para más información sobre el manejo por lotes.
HTTP
<dependency>
<groupId>com.iconsolutions.ipf.core.processingdata</groupId>
<artifactId>ipf-processing-data-ingress-http</artifactId>
</dependency>Responde a solicitudes http POST que contienen un sobre de IPF Processing Data con el estado http ACCEPTED (202).
El endpoint es un controlador de spring webflux y, por lo tanto, debe vivir dentro de una aplicación spring webflux. La configuración específica de spring-framework y spring-web se puede encontrar en spring.io.