Ingreso Processing Data

Resumen

Los módulos ipf-processing-data-ingress deben ser utilizados en aplicaciones que necesiten consumir datos de procesamiento ipf, por ejemplo,ODS.

Transporte

El ipf-processing-data egress envía IPF Processing Data sobres sobre kafka, o http, y hay componentes ingress correspondientes 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 predeterminado Descripción

ipf.processing-data.ingress.transport

kafka

Habilite o deshabilite el ingreso de kafka. Cualquier cosa diferente de kafka lo desactivará.

ipf.processing-data.ingress.kafka.consumer.topic

IPF_PROCESSING_DATA

El tema del cual consumir IPF Processing Data sobres.

ipf.processing-data.ingress.kafka.consumer.topics

Los temas de los cuales consumir IPF Processing Data sobres, p. ej.[ TOPIC_A, TOPIC_B ]

El ingreso de Kafka utiliza un kafka receive connector, configuración adicional bajo la clave ipf.processing-data.ingress.kafka.consumer.* se puede encontrar en el Configuración del conector or Kafka Introducción Rápida.

Métricas

Las siguientes métricas serán reportadas por el ingreso de kafka:

  • ipf_processing_data_ingest_latency, que registra la duración entre el momento en que los objetos de Proceso (domain event, evento del sistema, registro de mensajes..), MDS objetos,PDS Los objetos y los objetos personalizados han sido creados y el tiempo que han sido procesados con éxito por el consumidor de Ingress; las duraciones serán sensibles a la desviación temporal entre los servidores, por lo que deben ser tratadas únicamente como estimaciones.

  • ipf_processing_data_ingress_batch_receive_size, que registra el tamaño de cada DataEnvelope lote recibido por su BatchedIpfProcessingDataHandler Spring bean. Consulte el guide to consuming processing data para más información sobre el manejo de lotes.

HTTP

<dependency>
    <groupId>com.iconsolutions.ipf.core.processingdata</groupId>
    <artifactId>ipf-processing-data-ingress-http</artifactId>
</dependency>

Responde a http POST requests containing an IPF Processing Data sobre con estado http ACCEPTED (202).

El punto final es un controlador de spring webflux y, por lo tanto, deberá residir dentro de una aplicación de spring webflux. La configuración específica para spring-framework y spring-web se puede encontrar en spring.io.