feat: use db_system,db_host tags (#82)

innerpeacez · web-flow · commit bf20c05e3852 · 2022-02-08T16:47:07.000+08:00
* db_type -&gt; db_system

* host -&gt; db_host
diff --git a/agent-core/src/main/java/cloud/erda/agent/core/utils/Constants.java b/agent-core/src/main/java/cloud/erda/agent/core/utils/Constants.java
@@ -98,13 +98,13 @@ public static class Tags {
 
         public static final String SPAN_LAYER_MQ = "mq";
 
-        public static final String HOST = "host";
+        public static final String DB_HOST = "db_host";
 
         public static final String DUBBO_SERVICE = "dubbo_service";
 
         public static final String DUBBO_METHOD = "dubbo_method";
 
-        public static final String DB_TYPE = "db_type";
+        public static final String DB_SYSTEM = "db_system";
 
         public static final String DB_TYPE_REDIS = "Redis";
 
diff --git a/agent-plugins/agent-dubbo-2.7.x-plugin/src/main/java/cloud/erda/agent/plugin/asf/dubbo/DubboInterceptor.java b/agent-plugins/agent-dubbo-2.7.x-plugin/src/main/java/cloud/erda/agent/plugin/asf/dubbo/DubboInterceptor.java
@@ -102,7 +102,7 @@ public void beforeMethod(IMethodInterceptContext context, MethodInterceptResult
                     .tag(Constants.Tags.SPAN_KIND, Constants.Tags.SPAN_KIND_SERVER)
                     .tag(Constants.Tags.PEER_ADDRESS, rpcContext.getRemoteAddressString())
                     .tag(Constants.Tags.PEER_SERVICE, invoker.getInterface().getName() + "." + invocation.getMethodName())
-                    .tag(Constants.Tags.HOST, rpcContext.getLocalAddressString())
+                    .tag(Constants.Tags.DB_HOST, rpcContext.getLocalAddressString())
                     .tag(Constants.Tags.DUBBO_SERVICE, invoker.getInterface().getName())
                     .tag(Constants.Tags.DUBBO_METHOD, invocation.getMethodName());
         }
@@ -113,7 +113,7 @@ public void beforeMethod(IMethodInterceptContext context, MethodInterceptResult
         span.tag(Constants.Tags.PEER_ADDRESS, rpcContext.getRemoteAddressString());
         span.tag(Constants.Tags.PEER_SERVICE, invoker.getInterface().getName() + "." + invocation.getMethodName());
         span.tag(Constants.Tags.SPAN_LAYER, Constants.Tags.SPAN_LAYER_RPC);
-        span.tag(Constants.Tags.HOST, rpcContext.getLocalAddressString());
+        span.tag(Constants.Tags.DB_HOST, rpcContext.getLocalAddressString());
         span.tag(Constants.Tags.DUBBO_SERVICE, invoker.getInterface().getName());
         span.tag(Constants.Tags.DUBBO_METHOD, invocation.getMethodName());
     }
diff --git a/agent-plugins/agent-dubbo-plugin/src/main/java/cloud/erda/agent/plugin/dubbo/DubboInterceptor.java b/agent-plugins/agent-dubbo-plugin/src/main/java/cloud/erda/agent/plugin/dubbo/DubboInterceptor.java
@@ -97,7 +97,7 @@ public void beforeMethod(IMethodInterceptContext context, MethodInterceptResult
                     .tag(Constants.Tags.SPAN_KIND, Constants.Tags.SPAN_KIND_SERVER)
                     .tag(Constants.Tags.PEER_ADDRESS, rpcContext.getRemoteAddressString())
                     .tag(Constants.Tags.PEER_SERVICE, invoker.getInterface().getName() + "." + invocation.getMethodName())
-                    .tag(Constants.Tags.HOST, rpcContext.getLocalAddressString())
+                    .tag(Constants.Tags.DB_HOST, rpcContext.getLocalAddressString())
                     .tag(Constants.Tags.DUBBO_SERVICE, invoker.getInterface().getName())
                     .tag(Constants.Tags.DUBBO_METHOD, invocation.getMethodName());
         }
@@ -107,7 +107,7 @@ public void beforeMethod(IMethodInterceptContext context, MethodInterceptResult
         span.tag(Constants.Tags.PEER_ADDRESS, rpcContext.getRemoteAddressString());
         span.tag(Constants.Tags.PEER_SERVICE, invoker.getInterface().getName() + "." + invocation.getMethodName());
         span.tag(Constants.Tags.SPAN_LAYER, Constants.Tags.SPAN_LAYER_RPC);
-        span.tag(Constants.Tags.HOST, rpcContext.getLocalAddressString());
+        span.tag(Constants.Tags.DB_HOST, rpcContext.getLocalAddressString());
         span.tag(Constants.Tags.DUBBO_SERVICE, invoker.getInterface().getName());
         span.tag(Constants.Tags.DUBBO_METHOD, invocation.getMethodName());
     }
diff --git a/agent-plugins/agent-jdbc-plugins/agent-jdbc-commons/src/main/java/cloud/erda/agent/plugin/jdbc/ExecuteMethodsInterceptor.java b/agent-plugins/agent-jdbc-plugins/agent-jdbc-commons/src/main/java/cloud/erda/agent/plugin/jdbc/ExecuteMethodsInterceptor.java
@@ -61,10 +61,10 @@ public void beforeMethod(IMethodInterceptContext context, MethodInterceptResult
             span.tag(Constants.Tags.SPAN_KIND, Constants.Tags.SPAN_KIND_CLIENT);
             span.tag(Constants.Tags.DB_INSTANCE, connectInfo.getDatabaseName());
             span.tag(Constants.Tags.DB_STATEMENT, statement);
-            span.tag(Constants.Tags.DB_TYPE, connectInfo.getDBType());
+            span.tag(Constants.Tags.DB_SYSTEM, connectInfo.getDBType());
             span.tag(Constants.Tags.SPAN_LAYER, Constants.Tags.SPAN_LAYER_DB);
             span.tag(Constants.Tags.COMPONENT, connectInfo.getComponent());
-            span.tag(Constants.Tags.HOST, connectInfo.getDatabasePeer());
+            span.tag(Constants.Tags.DB_HOST, connectInfo.getDatabasePeer());
             span.tag(Constants.Tags.PEER_ADDRESS, connectInfo.getDatabasePeer());
             span.tag(Constants.Tags.PEER_SERVICE, connectInfo.getDatabasePeer());
             if (Strings.isEmpty(statement)) {
@@ -77,10 +77,10 @@ public void beforeMethod(IMethodInterceptContext context, MethodInterceptResult
                     .tag(Constants.Tags.PEER_HOSTNAME, connectInfo.getDatabasePeer())
                     .tag(Constants.Tags.PEER_ADDRESS, connectInfo.getDatabasePeer())
                     .tag(Constants.Tags.PEER_SERVICE, connectInfo.getDatabasePeer())
-                    .tag(Constants.Tags.HOST, connectInfo.getDatabasePeer())
+                    .tag(Constants.Tags.DB_HOST, connectInfo.getDatabasePeer())
                     .tag(Constants.Tags.DB_INSTANCE, connectInfo.getDatabaseName())
                     .tag(Constants.Tags.DB_STATEMENT, statement)
-                    .tag(Constants.Tags.DB_TYPE, connectInfo.getDBType());
+                    .tag(Constants.Tags.DB_SYSTEM, connectInfo.getDBType());
         }
     }
 
diff --git a/agent-plugins/agent-jedis-2.x-plugin/src/main/java/cloud/erda/agent/plugin/jedis/v2/JedisMethodInterceptor.java b/agent-plugins/agent-jedis-2.x-plugin/src/main/java/cloud/erda/agent/plugin/jedis/v2/JedisMethodInterceptor.java
@@ -30,7 +30,6 @@
 import cloud.erda.agent.plugin.app.insight.transaction.TransactionMetricUtils;
 import org.apache.skywalking.apm.agent.core.plugin.interceptor.context.IMethodInterceptContext;
 import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.DynamicFieldEnhancedInstance;
-import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.EnhancedInstance;
 import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.InstanceMethodsAroundInterceptor;
 import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.MethodInterceptResult;
 
@@ -60,12 +59,12 @@ public void beforeMethod(IMethodInterceptContext context, MethodInterceptResult
         SpanContext spanContext = tracer.active() != null ? tracer.active().span().getContext() : null;
         SpanBuilder spanBuilder = tracer.buildSpan("Jedis/" + method.getName());
         Span span = spanBuilder.childOf(spanContext).startActive().span();
-        span.tag(Constants.Tags.DB_TYPE, Constants.Tags.DB_TYPE_REDIS);
+        span.tag(Constants.Tags.DB_SYSTEM, Constants.Tags.DB_TYPE_REDIS);
         span.tag(Constants.Tags.COMPONENT, Constants.Tags.COMPONENT_JEDIS);
         span.tag(Constants.Tags.PEER_SERVICE, peer);
         span.tag(Constants.Tags.SPAN_LAYER, Constants.Tags.SPAN_LAYER_CACHE);
         span.tag(Constants.Tags.SPAN_KIND, Constants.Tags.SPAN_KIND_CLIENT);
-        span.tag(Constants.Tags.HOST, peer);
+        span.tag(Constants.Tags.DB_HOST, peer);
         span.tag(Constants.Tags.DB_STATEMENT, statement);
         span.tag(Constants.Tags.PEER_ADDRESS, peer);
         span.tag(Constants.Tags.PEER_HOSTNAME, peer);
@@ -78,9 +77,9 @@ public void beforeMethod(IMethodInterceptContext context, MethodInterceptResult
                 .tag(Constants.Tags.PEER_SERVICE, peer)
                 .tag(Constants.Tags.PEER_ADDRESS, peer)
                 .tag(Constants.Tags.PEER_HOSTNAME, peer)
-                .tag(Constants.Tags.HOST, peer)
+                .tag(Constants.Tags.DB_HOST, peer)
                 .tag(Constants.Tags.DB_STATEMENT, statement)
-                .tag(Constants.Tags.DB_TYPE, Constants.Tags.DB_TYPE_REDIS);
+                .tag(Constants.Tags.DB_SYSTEM, Constants.Tags.DB_TYPE_REDIS);
     }
 
     @Override
diff --git a/agent-plugins/agent-lettuce-plugins/agent-lettuce-5.x-plugin/src/main/java/cloud/erda/agent/plugin/lettuce/v5/AsyncCommandMethodInterceptor.java b/agent-plugins/agent-lettuce-plugins/agent-lettuce-5.x-plugin/src/main/java/cloud/erda/agent/plugin/lettuce/v5/AsyncCommandMethodInterceptor.java
@@ -45,7 +45,7 @@ public void beforeMethod(IMethodInterceptContext context, MethodInterceptResult
         SpanBuilder spanBuilder = tracer.buildSpan(operationName + "/onComplete");
         Span span = spanBuilder.childOf(spanContext).startActive().span();
         span.tag(Constants.Tags.COMPONENT, Constants.Tags.COMPONENT_LETTUCE);
-        span.tag(Constants.Tags.DB_TYPE, Constants.Tags.DB_TYPE_REDIS);
+        span.tag(Constants.Tags.DB_SYSTEM, Constants.Tags.DB_TYPE_REDIS);
         span.tag(Constants.Tags.SPAN_LAYER, Constants.Tags.SPAN_LAYER_CACHE);
         TracerSnapshot snapshot = TracerManager.currentTracer().capture();
         if (context.getArguments()[0] instanceof Consumer) {
diff --git a/agent-plugins/agent-lettuce-plugins/agent-lettuce-5.x-plugin/src/main/java/cloud/erda/agent/plugin/lettuce/v5/RedisChannelWriterInterceptor.java b/agent-plugins/agent-lettuce-plugins/agent-lettuce-5.x-plugin/src/main/java/cloud/erda/agent/plugin/lettuce/v5/RedisChannelWriterInterceptor.java
@@ -65,14 +65,14 @@ public void beforeMethod(IMethodInterceptContext context, MethodInterceptResult
 
         SpanBuilder spanBuilder = tracer.buildSpan(operationName + "/" + context.getMethod().getName());
         Span span = spanBuilder.childOf(spanContext).startActive().span();
-        span.tag(Constants.Tags.DB_TYPE, Constants.Tags.DB_TYPE_REDIS);
+        span.tag(Constants.Tags.DB_SYSTEM, Constants.Tags.DB_TYPE_REDIS);
         span.tag(Constants.Tags.COMPONENT, Constants.Tags.COMPONENT_LETTUCE);
         span.tag(Constants.Tags.PEER_SERVICE, peer);
         span.tag(Constants.Tags.PEER_ADDRESS, peer);
         span.tag(Constants.Tags.PEER_HOSTNAME, peer);
         span.tag(Constants.Tags.SPAN_LAYER, Constants.Tags.SPAN_LAYER_CACHE);
         span.tag(Constants.Tags.SPAN_KIND, Constants.Tags.SPAN_KIND_CLIENT);
-        span.tag(Constants.Tags.HOST, peer);
+        span.tag(Constants.Tags.DB_HOST, peer);
         span.tag(Constants.Tags.DB_STATEMENT, dbStatement.toString());
 
         if (Strings.isEmpty(dbStatement.toString())) {
@@ -84,9 +84,9 @@ public void beforeMethod(IMethodInterceptContext context, MethodInterceptResult
         transactionMetricBuilder.tag(Constants.Tags.COMPONENT, Constants.Tags.COMPONENT_LETTUCE)
                 .tag(Constants.Tags.SPAN_KIND, Constants.Tags.SPAN_KIND_CLIENT)
                 .tag(Constants.Tags.PEER_SERVICE, peer)
-                .tag(Constants.Tags.HOST, peer)
+                .tag(Constants.Tags.DB_HOST, peer)
                 .tag(Constants.Tags.DB_STATEMENT, dbStatement.toString())
-                .tag(Constants.Tags.DB_TYPE, Constants.Tags.DB_TYPE_REDIS);
+                .tag(Constants.Tags.DB_SYSTEM, Constants.Tags.DB_TYPE_REDIS);
     }
 
     @Override
diff --git a/agent-plugins/agent-lettuce-plugins/agent-lettuce-5.x-plugin/src/main/java/cloud/erda/agent/plugin/lettuce/v5/SpotBiConsumer.java b/agent-plugins/agent-lettuce-plugins/agent-lettuce-5.x-plugin/src/main/java/cloud/erda/agent/plugin/lettuce/v5/SpotBiConsumer.java
@@ -44,7 +44,7 @@ public void accept(T t, U u) {
         SpanBuilder spanBuilder = tracer.buildSpan(operationName + "/accept");
         Scope scope = spanBuilder.childOf(snapshotScope.span().getContext()).startActive();
         scope.span().tag(Constants.Tags.COMPONENT, Constants.Tags.COMPONENT_LETTUCE);
-        scope.span().tag(Constants.Tags.DB_TYPE, Constants.Tags.DB_TYPE_REDIS);
+        scope.span().tag(Constants.Tags.DB_SYSTEM, Constants.Tags.DB_TYPE_REDIS);
         scope.span().tag(Constants.Tags.SPAN_LAYER, Constants.Tags.SPAN_LAYER_CACHE);
         scope.span().tag(Constants.Tags.SPAN_KIND, Constants.Tags.SPAN_KIND_CLIENT);
         try {
diff --git a/agent-plugins/agent-lettuce-plugins/agent-lettuce-5.x-plugin/src/main/java/cloud/erda/agent/plugin/lettuce/v5/SpotConsumer.java b/agent-plugins/agent-lettuce-plugins/agent-lettuce-5.x-plugin/src/main/java/cloud/erda/agent/plugin/lettuce/v5/SpotConsumer.java
@@ -44,7 +44,7 @@ public void accept(T t) {
         SpanBuilder spanBuilder = tracer.buildSpan(operationName + "/accept");
         Scope scope = spanBuilder.childOf(snapshotScope.span().getContext()).startActive();
         scope.span().tag(Constants.Tags.COMPONENT, Constants.Tags.COMPONENT_LETTUCE);
-        scope.span().tag(Constants.Tags.DB_TYPE, Constants.Tags.DB_TYPE_REDIS);
+        scope.span().tag(Constants.Tags.DB_SYSTEM, Constants.Tags.DB_TYPE_REDIS);
         scope.span().tag(Constants.Tags.SPAN_LAYER, Constants.Tags.SPAN_LAYER_CACHE);
         scope.span().tag(Constants.Tags.SPAN_KIND, Constants.Tags.SPAN_KIND_CLIENT);
         try {
diff --git a/agent-plugins/agent-redisson-3.x-plugin/src/main/java/cloud/erda/agent/plugin/redisson/v3/CommandAsyncInterceptor.java b/agent-plugins/agent-redisson-3.x-plugin/src/main/java/cloud/erda/agent/plugin/redisson/v3/CommandAsyncInterceptor.java
@@ -28,7 +28,6 @@
 import org.apache.skywalking.apm.agent.core.plugin.interceptor.context.IMethodInterceptContext;
 import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.InstanceMethodsAroundInterceptor;
 import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.MethodInterceptResult;
-import org.redisson.api.RFuture;
 
 import java.lang.reflect.Method;
 
@@ -47,7 +46,7 @@ public void beforeMethod(IMethodInterceptContext context, MethodInterceptResult
         SpanBuilder spanBuilder = tracer.buildSpan("Redisson CommandExecutor:" + context.getMethod().getName());
         Scope scope = spanBuilder.childOf(spanContext).startActive();
         Span span = scope.span();
-        span.tag(Constants.Tags.DB_TYPE, Constants.Tags.DB_TYPE_REDIS);
+        span.tag(Constants.Tags.DB_SYSTEM, Constants.Tags.DB_TYPE_REDIS);
         span.tag(Constants.Tags.COMPONENT, Constants.Tags.COMPONENT_REDISSON);
         span.tag(Constants.Tags.SPAN_LAYER, Constants.Tags.SPAN_LAYER_LOCAL);
         span.tag(Constants.Tags.SPAN_KIND, Constants.Tags.SPAN_KIND_LOCAL);
diff --git a/agent-plugins/agent-redisson-3.x-plugin/src/main/java/cloud/erda/agent/plugin/redisson/v3/ConnectionOpInterceptor.java b/agent-plugins/agent-redisson-3.x-plugin/src/main/java/cloud/erda/agent/plugin/redisson/v3/ConnectionOpInterceptor.java
@@ -28,7 +28,6 @@
 import org.apache.skywalking.apm.agent.core.plugin.interceptor.context.IMethodInterceptContext;
 import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.InstanceMethodsAroundInterceptor;
 import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.MethodInterceptResult;
-import org.redisson.connection.NodeSource;
 
 import java.lang.reflect.Method;
 
@@ -47,7 +46,7 @@ public void beforeMethod(IMethodInterceptContext context, MethodInterceptResult
         SpanBuilder spanBuilder = tracer.buildSpan("Redisson ConnectionManager Connection");
         Scope scope = spanBuilder.childOf(spanContext).startActive();
         Span span = scope.span();
-        span.tag(Constants.Tags.DB_TYPE, Constants.Tags.DB_TYPE_REDIS);
+        span.tag(Constants.Tags.DB_SYSTEM, Constants.Tags.DB_TYPE_REDIS);
         span.tag(Constants.Tags.COMPONENT, Constants.Tags.COMPONENT_REDISSON);
         span.tag(Constants.Tags.SPAN_LAYER, Constants.Tags.SPAN_LAYER_LOCAL);
         span.tag(Constants.Tags.SPAN_KIND, Constants.Tags.SPAN_KIND_LOCAL);
diff --git a/agent-plugins/agent-redisson-3.x-plugin/src/main/java/cloud/erda/agent/plugin/redisson/v3/RedisConnectionSendInterceptor.java b/agent-plugins/agent-redisson-3.x-plugin/src/main/java/cloud/erda/agent/plugin/redisson/v3/RedisConnectionSendInterceptor.java
@@ -26,9 +26,7 @@
 import cloud.erda.agent.core.tracing.span.SpanBuilder;
 import cloud.erda.agent.core.utils.Constants;
 import cloud.erda.agent.core.utils.ReflectUtils;
-import cloud.erda.agent.plugin.app.insight.MetricReporter;
 import cloud.erda.agent.plugin.app.insight.transaction.TransactionMetricBuilder;
-import cloud.erda.agent.plugin.app.insight.transaction.TransactionMetricUtils;
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelFuture;
@@ -105,12 +103,12 @@ public void beforeMethod(IMethodInterceptContext context, MethodInterceptResult
         // only build span, and removes the span from the thread context
         Scope scope = spanBuilder.childOf(spanContext).startActive(false);
         Span span = scope.span();
-        span.tag(Constants.Tags.DB_TYPE, Constants.Tags.DB_TYPE_REDIS);
+        span.tag(Constants.Tags.DB_SYSTEM, Constants.Tags.DB_TYPE_REDIS);
         span.tag(Constants.Tags.COMPONENT, Constants.Tags.COMPONENT_REDISSON);
         span.tag(Constants.Tags.PEER_SERVICE, peer);
         span.tag(Constants.Tags.SPAN_LAYER, Constants.Tags.SPAN_LAYER_CACHE);
         span.tag(Constants.Tags.SPAN_KIND, Constants.Tags.SPAN_KIND_CLIENT);
-        span.tag(Constants.Tags.HOST, peer);
+        span.tag(Constants.Tags.DB_HOST, peer);
         span.tag(Constants.Tags.DB_STATEMENT, dbStatement.toString());
         span.tag(Constants.Tags.PEER_ADDRESS, peer);
         span.tag(Constants.Tags.PEER_HOSTNAME, peer);
@@ -123,9 +121,9 @@ public void beforeMethod(IMethodInterceptContext context, MethodInterceptResult
                 .tag(Constants.Tags.PEER_SERVICE, peer)
                 .tag(Constants.Tags.PEER_ADDRESS, peer)
                 .tag(Constants.Tags.PEER_HOSTNAME, peer)
-                .tag(Constants.Tags.HOST, peer)
+                .tag(Constants.Tags.DB_HOST, peer)
                 .tag(Constants.Tags.DB_STATEMENT, dbStatement.toString())
-                .tag(Constants.Tags.DB_TYPE, Constants.Tags.DB_TYPE_REDIS);
+                .tag(Constants.Tags.DB_SYSTEM, Constants.Tags.DB_TYPE_REDIS);
     }
 
     private void addCommandData(StringBuilder dbStatement, CommandData commandData) {
diff --git a/agent-plugins/agent-rocketmq-4.x-plugin/src/main/java/cloud/erda/agent/plugin/rocketmq/v4/AbstractMessageConsumeInterceptor.java b/agent-plugins/agent-rocketmq-4.x-plugin/src/main/java/cloud/erda/agent/plugin/rocketmq/v4/AbstractMessageConsumeInterceptor.java
@@ -78,15 +78,15 @@ public final void beforeMethod(IMethodInterceptContext context, MethodInterceptR
         span.tag(Constants.Tags.SPAN_KIND, Constants.Tags.SPAN_KIND_CONSUMER);
         span.tag(Constants.Tags.SPAN_LAYER, Constants.Tags.SPAN_LAYER_MQ);
         span.tag(Constants.Tags.PEER_ADDRESS, nameServerAddress);
-        span.tag(Constants.Tags.HOST, nameServerAddress);
+        span.tag(Constants.Tags.DB_HOST, nameServerAddress);
         span.tag(Constants.Tags.MESSAGE_BUS_DESTINATION, topic);
 
         TransactionMetricBuilder transactionMetricBuilder = new TransactionMetricBuilder(Constants.Metrics.APPLICATION_MQ, true);
         context.setAttachment(Constants.Keys.METRIC_BUILDER, transactionMetricBuilder);
         transactionMetricBuilder.tag(Constants.Tags.COMPONENT, Constants.Tags.COMPONENT_ROCKETMQ)
                 .tag(Constants.Tags.SPAN_KIND, Constants.Tags.SPAN_KIND_CONSUMER)
                 .tag(Constants.Tags.PEER_ADDRESS, nameServerAddress)
-                .tag(Constants.Tags.HOST, nameServerAddress)
+                .tag(Constants.Tags.DB_HOST, nameServerAddress)
                 .tag(Constants.Tags.MESSAGE_BUS_DESTINATION, topic);
     }
 
diff --git a/agent-plugins/agent-rocketmq-4.x-plugin/src/main/java/cloud/erda/agent/plugin/rocketmq/v4/MessageSendInterceptor.java b/agent-plugins/agent-rocketmq-4.x-plugin/src/main/java/cloud/erda/agent/plugin/rocketmq/v4/MessageSendInterceptor.java
@@ -74,7 +74,7 @@ public void beforeMethod(IMethodInterceptContext context, MethodInterceptResult
         span.tag(SPAN_KIND, SPAN_KIND_PRODUCER);
         span.tag(SPAN_LAYER, SPAN_LAYER_MQ);
         span.tag(PEER_ADDRESS, nameServerAddress);
-        span.tag(HOST, nameServerAddress);
+        span.tag(DB_HOST, nameServerAddress);
         span.tag(MESSAGE_BUS_DESTINATION, message.getTopic());
 
         span.getContext().getBaggage().putAll(TransactionMetricContext.instance);
@@ -101,7 +101,7 @@ public void beforeMethod(IMethodInterceptContext context, MethodInterceptResult
         transactionMetricBuilder.tag(COMPONENT, COMPONENT_ROCKETMQ)
                 .tag(SPAN_KIND, SPAN_KIND_PRODUCER)
                 .tag(PEER_ADDRESS, nameServerAddress)
-                .tag(HOST, nameServerAddress)
+                .tag(DB_HOST, nameServerAddress)
                 .tag(MESSAGE_BUS_DESTINATION, message.getTopic());
         if (IS_SYNC.get()) {
             context.setAttachment(Constants.Keys.METRIC_BUILDER, transactionMetricBuilder);
diff --git a/agent-plugins/agent-servlet-plugins/agent-servlet-commons/src/main/java/cloud/erda/agent/plugin/servlet/BaseServletInvokeInterceptor.java b/agent-plugins/agent-servlet-plugins/agent-servlet-commons/src/main/java/cloud/erda/agent/plugin/servlet/BaseServletInvokeInterceptor.java
@@ -106,7 +106,7 @@ private void preRequest(IMethodInterceptContext context, HttpServletRequest requ
         context.setAttachment(Constants.Keys.TRACE_SCOPE, scope);
         Span span = scope.span();
         span.tag(Constants.Tags.HTTP_PATH, request.getRequestURI());
-        span.tag(Constants.Tags.HOST, host);
+        span.tag(Constants.Tags.DB_HOST, host);
         span.tag(Constants.Tags.HTTP_METHOD, request.getMethod());
         span.tag(Constants.Tags.HTTP_URL, request.getRequestURL().toString());
         span.tag(Constants.Tags.SPAN_LAYER, Constants.Tags.SPAN_LAYER_HTTP);
@@ -120,7 +120,7 @@ private void preRequest(IMethodInterceptContext context, HttpServletRequest requ
         context.setAttachment(Constants.Keys.METRIC_BUILDER, transactionMetricBuilder);
         transactionMetricBuilder.tag(Constants.Tags.COMPONENT, getComponent())
                 .tag(Constants.Tags.SPAN_KIND, Constants.Tags.SPAN_KIND_SERVER)
-                .tag(Constants.Tags.HOST, host)
+                .tag(Constants.Tags.DB_HOST, host)
                 .tag(Constants.Tags.PEER_ADDRESS, host)
                 .tag(Constants.Tags.HTTP_URL, request.getRequestURL().toString())
                 .tag(Constants.Tags.HTTP_PATH, request.getRequestURI())
