如何使用Camel推送路由运行指标到Datadog/Cloudwatch等外部服务

核心实现逻辑 #

Camel结合Micrometer实现指标采集+推送的核心逻辑为：将Camel指标注册表绑定到Micrometer全局注册表，再为Micrometer配置对应外部服务的导出器，启动后会自动按配置周期推送所有路由维度的统计指标，默认覆盖路由处理次数、耗时、异常数等核心统计项。

前置依赖配置 #

以Maven依赖为例，需引入对应组件：

• 基础依赖：camel-micrometer-starter（Spring Boot场景）或camel-micrometer（普通Java场景）
• Datadog推送额外依赖：micrometer-registry-datadog
• CloudWatch推送额外依赖：micrometer-registry-cloudwatch2（对应AWS SDK v2版本）

完整实现示例 #

1. Spring Boot场景配置示例 #

Datadog推送配置（application.yml）

management:
  metrics:
    export:
      datadog:
        enabled: true
        api-key: 你的Datadog API密钥
        step: 30s # 指标推送周期
        tags:
          application: 你的应用标识
  camel:
    metrics:
      enable-route-policy: true # 开启路由级指标自动采集
      enable-message-history: true # 可选，开启消息链路维度指标

CloudWatch推送配置（application.yml）

management:
  metrics:
    export:
      cloudwatch:
        enabled: true
        namespace: 你的CloudWatch指标命名空间
        step: 60s # 指标推送周期
  camel:
    metrics:
      enable-route-policy: true

2. 普通Java场景代码示例（以Datadog为例） #

import io.micrometer.datadog.DatadogMeterRegistry;
import io.micrometer.datadog.DatadogConfig;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.micrometer.routepolicy.MicrometerRoutePolicyFactory;
import java.time.Duration;

// 初始化Datadog注册表
DatadogConfig datadogConfig = key -> {
    if ("datadog.apiKey".equals(key)) return "你的Datadog API密钥";
    if ("datadog.step".equals(key)) return Duration.ofSeconds(30).toString();
    return null;
};
DatadogMeterRegistry registry = DatadogMeterRegistry.builder(datadogConfig).build();

// 绑定指标注册表到Camel上下文
CamelContext context = new DefaultCamelContext();
MicrometerRoutePolicyFactory policyFactory = new MicrometerRoutePolicyFactory();
policyFactory.setMeterRegistry(registry);
context.addRoutePolicyFactory(policyFactory);

// 自定义路由，指标会自动采集推送
context.addRoutes(new RouteBuilder() {
    @Override
    public void configure() throws Exception {
        from("timer:testTimer?period=1000")
            .routeId("test-route-1") // routeId会作为指标标签，用于区分不同路由
            .setBody(constant("测试消息"))
            .to("log:testLog");
    }
});

context.start();

3. 路由维度指标说明 #

开启路由采集策略后，默认会生成以下带routeId标签的指标，可直接在Datadog/CloudWatch控制台按路由ID筛选查询：

• camel.route.exchanges.total：路由处理总请求数
• camel.route.exchanges.succeeded：路由处理成功请求数
• camel.route.exchanges.failed：路由处理失败请求数
• camel.route.processing.time：路由处理耗时分布统计

注意事项 #

• 如需自定义指标，可在路由逻辑中通过micrometer:counter:自定义指标名?tags=routeId=${routeId}组件直接打点，自定义指标会自动同步到配置的外部服务
• CloudWatch场景需确保应用运行环境拥有CloudWatch写入权限的IAM角色，无需额外配置AK/SK
• 指标推送频率可根据业务需求调整，高频推送会产生更高的云服务成本

内容的提问来源于stack exchange，提问作者John Kim