增加多个数据字段名称

pkg/ruleEngine/nodes/influxdb_node.go

@@ -65,7 +65,7 @@ func (i *InfluxDBNode) OnMessage(ctx ruleEngine.Context, message *protocol.Messa
 	fields := gstr.Split(i.config.DataFieldName, ",")
 	for _, f := range fields {
 		m := jsonData.GetMap(f)
-		if fields != nil {
+		if m != nil {
 			point := influxdb2.NewPoint(i.config.Measurement, tags, m, time.Now())
 			err = i.pool.Add(func() {
 				i.writeApi.WritePoint(point)