Exponer métricas de mensajes de canal spring integration amqp/jms a prometheus.

Answer

1. 

   davy.ai

   June 17, 2023 at 1:35 am

   Para habilitar métricas para alimentar estadísticas de mensajes desde una puerta de enlace RabbitMQ <=> MqSeries de Spring-Integration hacia Prometheus, puede seguir los siguientes pasos:

   1. El canal que está utilizando debe extender AbstractMessageChannel. Esto se menciona en la documentación.

   2. Necesita agregar un MeterRegistryBean para activar las métricas. El MeterRegistryBean es responsable de administrar y mantener las métricas. Puede utilizar cualquier implementación de MeterRegistry, pero una ampliamente utilizada es Micrometer. Puede agregar el siguiente código a su configuración de Spring para agregar un MeterRegistryBean:

      @Bean
      public MeterRegistry meterRegistry() {
         return new PrometheusMeterRegistry(PrometheusConfig.DEFAULT);
      }
      

      Asegúrese de agregar la dependencia micrometer-registry-prometheus en su archivo pom.xml.

   3. Una vez que haya agregado el MeterRegistryBean, puede utilizar Micrometer para definir métricas en su código. Por ejemplo, puede definir un contador para el número de mensajes recibidos:

      @Autowired
      private MeterRegistry meterRegistry;
      
      private final Counter messagesReceived = meterRegistry.counter("messages_received");
      
      public void receiveMessage(String message) {
         // procesar mensaje
         messagesReceived.increment();
      }
      

      En este ejemplo, cada vez que se llama el método receiveMessage, el contador messagesReceived se incrementa en uno.

   4. Para exponer las métricas a Prometheus, necesita agregar un PrometheusScrapingEndpoint a su configuración de Spring. Puede hacerlo agregando el siguiente código:

      @Bean
      public PrometheusScrapingEndpoint prometheusScrapingEndpoint(MeterRegistry meterRegistry) {
         PrometheusScrapingEndpoint endpoint = new PrometheusScrapingEndpoint(meterRegistry);
         endpoint.setBasePath("/actuator/prometheus");
         return endpoint;
      }
      

      El PrometheusScrapingEndpoint expone las métricas en un formato que Prometheus puede rascar (“scrapear”). En este ejemplo, el endpoint se expone en /actuator/prometheus.

      Asegúrese de agregar las dependencias micrometer-registry-prometheus-autoconfigure y spring-boot-starter-actuator en su archivo pom.xml.

   5. Finalmente, necesita configurar Prometheus para rascar las métricas de su aplicación. Puede agregar la siguiente configuración a su archivo prometheus.yml:

      scrape_configs:
       - job_name: 'myjob'
         static_configs:
           - targets: ['myapp:8080']
      

      En este ejemplo, myapp es el nombre de su aplicación y 8080 es el puerto donde se está ejecutando.

Comments are closed.