feat: 构件传输记录指标增加userId #2448

TencentBlueKing · Aug 1, 2024 · 4d819cd · 4d819cd
1 parent a0a939d
commit 4d819cd
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/...main/kotlin/com/tencent/bkrepo/common/artifact/event/listener/ArtifactTransferListener.kt b/...main/kotlin/com/tencent/bkrepo/common/artifact/event/listener/ArtifactTransferListener.kt
@@ -37,6 +37,7 @@ import com.tencent.bkrepo.common.artifact.constant.DEFAULT_STORAGE_KEY
 import com.tencent.bkrepo.common.artifact.event.ArtifactReceivedEvent
 import com.tencent.bkrepo.common.artifact.event.ArtifactResponseEvent
 import com.tencent.bkrepo.common.artifact.event.ChunkArtifactTransferEvent
+import com.tencent.bkrepo.common.artifact.hash.md5
 import com.tencent.bkrepo.common.artifact.metrics.ArtifactCacheMetrics
 import com.tencent.bkrepo.common.artifact.metrics.ArtifactMetrics
 import com.tencent.bkrepo.common.artifact.metrics.ArtifactMetricsProperties
@@ -107,7 +108,7 @@ class ArtifactTransferListener(
                     builderAgentList = artifactMetricsProperties.builderAgentList,
                     clientAgentList = artifactMetricsProperties.clientAgentList
                 ).name,
-                userId = SecurityUtils.getUserId()
+                userId = SecurityUtils.getUserId().md5()
             )
             if (SecurityUtils.getUserId() != SYSTEM_USER) {
                 projectUsageStatisticsService.inc(projectId = projectId, receivedBytes = throughput.bytes)
@@ -153,7 +154,7 @@ class ArtifactTransferListener(
                     builderAgentList = artifactMetricsProperties.builderAgentList,
                     clientAgentList = artifactMetricsProperties.clientAgentList
                 ).name,
-                userId = SecurityUtils.getUserId()
+                userId = SecurityUtils.getUserId().md5()
             )
             if (SecurityUtils.getUserId() != SYSTEM_USER) {
                 projectUsageStatisticsService.inc(projectId = projectId, responseBytes = throughput.bytes)
@@ -210,7 +211,7 @@ class ArtifactTransferListener(
                     builderAgentList = artifactMetricsProperties.builderAgentList,
                     clientAgentList = artifactMetricsProperties.clientAgentList
                 ).name,
-                userId = SecurityUtils.getUserId()
+                userId = SecurityUtils.getUserId().md5()
             )
             if (artifactMetricsProperties.collectByLog) {
                 logger.info(