diff --git a/root-cloud-event/src/main/java/com/qniao/iot/rc/RootCloudIotDataReceiptedEvent.java b/root-cloud-event/src/main/java/com/qniao/iot/rc/RootCloudIotDataReceiptedEvent.java index 400f26e..cbb00b6 100644 --- a/root-cloud-event/src/main/java/com/qniao/iot/rc/RootCloudIotDataReceiptedEvent.java +++ b/root-cloud-event/src/main/java/com/qniao/iot/rc/RootCloudIotDataReceiptedEvent.java @@ -1,6 +1,7 @@ package com.qniao.iot.rc; import com.fasterxml.jackson.annotation.JsonAutoDetect; +import com.fasterxml.jackson.annotation.JsonIgnoreProperties; import lombok.Data; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.annotation.JsonProperty; @@ -165,8 +166,8 @@ public class RootCloudIotDataReceiptedEvent implements Serializable { private Online __online__; - @JsonProperty(value = "__thingName__") - private String thingName; + @JsonIgnoreProperties(ignoreUnknown = true) + private String __thingName__; @Data public static class Online{ diff --git a/root-cloud-statistics/src/main/java/com/qniao/iot/rc/event/RootCloudIotDataReceiptedEventDeserializationSchema.java b/root-cloud-statistics/src/main/java/com/qniao/iot/rc/event/RootCloudIotDataReceiptedEventDeserializationSchema.java index ed72e70..7c6bd88 100644 --- a/root-cloud-statistics/src/main/java/com/qniao/iot/rc/event/RootCloudIotDataReceiptedEventDeserializationSchema.java +++ b/root-cloud-statistics/src/main/java/com/qniao/iot/rc/event/RootCloudIotDataReceiptedEventDeserializationSchema.java @@ -23,7 +23,6 @@ public class RootCloudIotDataReceiptedEventDeserializationSchema implements Dese @Override public RootCloudIotDataReceiptedEvent deserialize(byte[] message) throws IOException { - log.info("接受的设备数据:{}", JSONUtil.toJsonStr(message)); return objectMapper.readValue(message, RootCloudIotDataReceiptedEvent.class); }