diff --git a/consumers/consumerAXYraw.go b/consumers/consumerAXYraw.go index f52e5da..ccc79dd 100644 --- a/consumers/consumerAXYraw.go +++ b/consumers/consumerAXYraw.go @@ -149,7 +149,7 @@ func (the *consumerAXYraw) onData(topic string, msg string) bool { needPush := adaptor.Transform(topic, msg) - if needPush != nil { + if needPush != nil && len(needPush.Meta) > 0 { //日志标记 if needPush.IotaDevice == logTagDeviceId { bs, _ := json.Marshal(needPush)