如何为Elastic APM数据库指标自定义Span名称或子类型

针对你遇到的两个服务MySQL依赖显示混淆的问题，以下是几种低成本、可落地的解决方式，适配Elastic APM Java Agent 1.52.1版本：

方案1：直接通过Agent配置固定目标服务名 #

这是最简单的方式，针对不同服务配置专属的数据库目标服务标识：

• 对于stories服务，在Agent启动参数或apm-agent.properties中添加：

  elastic.apm.db.destination_service_resource=mysql-stories
  

• 对于ingest-api服务，配置：

  elastic.apm.db.destination_service_resource=mysql-ingest-api
  

配置后，APM可观测界面的依赖图会分别显示mysql-stories和mysql-ingest-api，直接区分两个MySQL集群。

方案2：用Instrumentation Rules配置动态区分 #

无需编写代码，通过YAML规则基于服务名自动修改Span属性：

1. 创建rules.yaml文件：

   - name: rename-stories-mysql-destination
     condition: "service.name == 'stories' and span.type == 'db' and span.subtype == 'mysql'"
     actions:
       - set:
           span.destination.service.resource: "mysql-stories"
   - name: rename-ingest-api-mysql-destination
     condition: "service.name == 'ingest-api' and span.type == 'db' and span.subtype == 'mysql'"
     actions:
       - set:
           span.destination.service.resource: "mysql-ingest-api"
   

2. 启动服务时指定规则文件路径：

   -javaagent:/path/to/elastic-apm-agent-1.52.1.jar -Delastic.apm.instrumentation_rules=/path/to/rules.yaml
   

方案3：自定义Span处理器（动态IP匹配场景） #

如果需要根据MySQL集群IP动态区分，可实现轻量的Span处理器：

1. 编写自定义Span处理器类：

   import co.elastic.apm.agent.impl.transaction.Span;
   import co.elastic.apm.agent.tracer.SpanProcessor;
   import java.util.Map;
   
   public class MysqlDestinationCustomizer implements SpanProcessor {
       private static final Map<String, String> DB_IP_TO_RESOURCE = Map.of(
           "10.10.10.10", "mysql-stories",
           "20.20.20.20", "mysql-ingest-api"
       );
   
       @Override
       public void onStart(Span span) {
           if ("db".equals(span.getType()) && "mysql".equals(span.getSubtype())) {
               String dbAddress = span.getContext().getDestination().getAddress();
               String customResource = DB_IP_TO_RESOURCE.get(dbAddress);
               if (customResource != null) {
                   span.getContext().getDestination().getService().setResource(customResource);
               }
           }
       }
   
       @Override
       public void onEnd(Span span) {}
   
       @Override
       public boolean isSampled(Span span) {
           return true;
       }
   }
   

2. 将类打包成Jar，启动时添加到Agent的bootstrap类路径：

   -javaagent:/path/to/elastic-apm-agent-1.52.1.jar -Delastic.apm.bootstrap_jar=/path/to/custom-processor.jar
   

补充说明 #

你之前尝试的JDBC URL添加applicationName参数无效，是因为该参数仅传递给MySQL服务器用于日志标识，Elastic APM Agent默认不会读取该值修改Span属性，因此无法区分依赖。

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