From 95c2bc33d39a0f252716541712a4f81205e5e9fe Mon Sep 17 00:00:00 2001 From: "1049970895@qniao.cn" <1049970895> Date: Mon, 30 Jan 2023 11:42:57 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/qniao/iot/rc/RootCloudIotDataReceiptedEvent.java | 5 +++-- .../RootCloudIotDataReceiptedEventDeserializationSchema.java | 1 - 2 files changed, 3 insertions(+), 3 deletions(-) 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); }