From f442a2c16226afb4f5d5e38d5f42b68498147b05 Mon Sep 17 00:00:00 2001 From: "1049970895@qniao.cn" <1049970895> Date: Mon, 30 Jan 2023 11:38:11 +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 --- .../RootCloudIotDataReceiptedEventDeserializationSchema.java | 3 +++ 1 file changed, 3 insertions(+) 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 58484b4..ed72e70 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 @@ -4,6 +4,7 @@ import cn.hutool.core.util.ByteUtil; import cn.hutool.json.JSONUtil; import com.fasterxml.jackson.databind.ObjectMapper; import com.qniao.iot.rc.RootCloudIotDataReceiptedEvent; +import lombok.extern.slf4j.Slf4j; import org.apache.flink.api.common.serialization.DeserializationSchema; import org.apache.flink.api.common.typeinfo.TypeInformation; @@ -12,6 +13,7 @@ import java.io.IOException; /** * @author Lzk */ +@Slf4j public class RootCloudIotDataReceiptedEventDeserializationSchema implements DeserializationSchema { /** * 注册JavaTimeModule，支持LocalDateTime字段的解析 @@ -21,6 +23,7 @@ public class RootCloudIotDataReceiptedEventDeserializationSchema implements Dese @Override public RootCloudIotDataReceiptedEvent deserialize(byte[] message) throws IOException { + log.info("接受的设备数据：{}", JSONUtil.toJsonStr(message)); return objectMapper.readValue(message, RootCloudIotDataReceiptedEvent.class); }