diff --git a/consumers/consumerAXYraw.go b/consumers/consumerAXYraw.go index 25a755c..e6de74f 100644 --- a/consumers/consumerAXYraw.go +++ b/consumers/consumerAXYraw.go @@ -163,7 +163,9 @@ func (the *consumerAXYraw) onData(topic string, msg string) bool { } else { s, _ := json.Marshal(needPush) if needPush != nil { - log.Printf("onData 设备[%s] 异常needPush= %s", needPush.IotaDevice, s) + if needPush.IotaDevice == logTagDeviceId { + log.Printf("onData 设备[%s] 异常needPush= %s", needPush.IotaDevice, s) + } } }