diff --git a/adaptors/安心云最新设备数据toES.go b/adaptors/安心云最新设备数据toES.go index 1d3dba0..2b255b2 100644 --- a/adaptors/安心云最新设备数据toES.go +++ b/adaptors/安心云最新设备数据toES.go @@ -24,7 +24,7 @@ func (the Adaptor_AXY_LastRAW) Transform(topic, rawMsg string) *models.EsRaw { } func (the Adaptor_AXY_LastRAW) raw2es(iotaData models.IotaData) *models.EsRaw { - if !iotaData.Data.Success() { + if len(iotaData.Data.Data) == 0 { return nil } //log.Printf("设备[%s] 数据时间 %s", iotaData.DeviceId, iotaData.TriggerTime)