From a77dc15e363ae4ef375f4dacd73fd2d7e1e0095b Mon Sep 17 00:00:00 2001
From: ning <710leo@gmail.com>
Date: Tue, 16 May 2023 10:19:16 +0800
Subject: [PATCH] fix: ts fill tags

---
 pushgw/router/router_remotewrite.go | 13 +++++++------
 1 file changed, 7 insertions(+), 6 deletions(-)

diff --git a/pushgw/router/router_remotewrite.go b/pushgw/router/router_remotewrite.go
index d72e3502..0f5c0288 100644
--- a/pushgw/router/router_remotewrite.go
+++ b/pushgw/router/router_remotewrite.go
@@ -90,6 +90,13 @@ func (rt *Router) remoteWrite(c *gin.Context) {
 		}
 
 		ident = extractIdentFromTimeSeries(req.Timeseries[i])
+		if len(ident) > 0 {
+			// fill tags
+			target, has := rt.TargetCache.Get(ident)
+			if has {
+				rt.AppendLabels(req.Timeseries[i], target, rt.BusiGroupCache)
+			}
+		}
 
 		// telegraf 上报数据的场景，只有在 metric 为 system_load1 时，说明指标来自机器，将 host 改为 ident，其他情况都忽略
 		if extractMetricFromTimeSeries(req.Timeseries[i]) != "system_load1" {
@@ -99,12 +106,6 @@ func (rt *Router) remoteWrite(c *gin.Context) {
 		if len(ident) > 0 {
 			// register host
 			ids[ident] = struct{}{}
-
-			// fill tags
-			target, has := rt.TargetCache.Get(ident)
-			if has {
-				rt.AppendLabels(req.Timeseries[i], target, rt.BusiGroupCache)
-			}
 		}
 
 		rt.EnrichLabels(req.Timeseries[i])
-- 
GitLab