From 290f8bff51201b10960c020cf372b1b91ba7bc92 Mon Sep 17 00:00:00 2001 From: dongdong Date: Mon, 4 Dec 2023 19:17:36 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=E6=97=A5=E5=BF=97?= =?UTF-8?q?=E8=87=AA=E5=AE=9A=E4=B9=89=E6=8C=87=E6=A0=87=E4=B8=8A=E6=8A=A5?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E6=A0=BC=E5=BC=8F=E6=B8=85=E6=B4=97=E5=85=BC?= =?UTF-8?q?=E5=AE=B9=E9=97=AE=E9=A2=98=20(#83)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pkg/transfer/template/etl/timeseriesv2.go | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/pkg/transfer/template/etl/timeseriesv2.go b/pkg/transfer/template/etl/timeseriesv2.go index bdffff361..ac1cf05c1 100644 --- a/pkg/transfer/template/etl/timeseriesv2.go +++ b/pkg/transfer/template/etl/timeseriesv2.go @@ -55,12 +55,11 @@ func (p *TimeseriesV2Handler) Process(d define.Payload, outputChan chan<- define // 兼容逻辑 // 日志指标上报存在一种看起来像自定义指标但实际上又不是自定义指标的数据格式 for i := 0; i < len(records.Data); i++ { - item := records.Data[i] - if item.Timestamp == nil { - item.Timestamp = records.Timestamp + if records.Data[i].Timestamp == nil { + records.Data[i].Timestamp = records.Timestamp } - if item.Target == "" { - item.Target = records.Target + if records.Data[i].Target == "" { + records.Data[i].Target = records.Target } }