|
@ -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 { |
|
|
func (the Adaptor_AXY_LastRAW) raw2es(iotaData models.IotaData) *models.EsRaw { |
|
|
if !iotaData.Data.Success() { |
|
|
if len(iotaData.Data.Data) == 0 { |
|
|
return nil |
|
|
return nil |
|
|
} |
|
|
} |
|
|
//log.Printf("设备[%s] 数据时间 %s", iotaData.DeviceId, iotaData.TriggerTime)
|
|
|
//log.Printf("设备[%s] 数据时间 %s", iotaData.DeviceId, iotaData.TriggerTime)
|
|
|