Java函数如何使云计算中的物联网开发更敏捷？

import functions.eventpojos.PubsubMessage;
import net.minidev.json.JSONObject;
import java.nio.charset.StandardCharsets;
import java.util.Base64;

public class DataFilterFunction {

    public PubsubMessage filterData(PubsubMessage message) {
        // 将 PubSub 消息体解码为 JSON
        JSONObject data = new JSONObject(new String(
                Base64.getDecoder().decode(message.getData().getBytes(StandardCharsets.UTF_8)),
                StandardCharsets.UTF_8));

        // 过滤温度超过阈值的数据
        if (data.containsKey("temperature") && (double)data.get("temperature") > 100.0) {
            // 发布过滤后的数据
            JSONObject filteredData = new JSONObject();
            filteredData.put("temperature", data.get("temperature"));
            return PubsubMessage.builder()
                    .setData(Base64.getEncoder().encodeToString(
                            filteredData.toJSONString().getBytes(StandardCharsets.UTF_8)))
                    .build();
        }

        return null; // 丢弃低于阈值的数据
    }
}