java - Azure IoTHub DeviceMessage,消息正文上的路由过滤器不起作用
问题描述
遥测模拟器(Java 使用 com.microsoft.azure.sdk.iot -> iot-device-client -> 1.14.0 版本)
public class SimulatedDevice {
// The device connection string to authenticate the device with your IoT hub.
// Using the Azure CLI:
// az iot hub device-identity show-connection-string --hub-name {YourIoTHubName}
// --device-id MyJavaDevice --output table
private static String connString = "#ConnectionString";
private static IotHubClientProtocol protocol = IotHubClientProtocol.AMQPS;
private static DeviceClient client;
// Specify the telemetry to send to your IoT hub.
private static class TelemetryDataPoint {
public double temperature;
public double humidity;
public String isTrue = "true";
// Serialize object to JSON format.
public String serialize() {
Gson gson = new Gson();
return gson.toJson(this);
}
}
// Print the acknowledgement received from IoT Hub for the telemetry message
// sent.
private static class EventCallback implements IotHubEventCallback {
public void execute(IotHubStatusCode status, Object context) {
System.out.println("IoT Hub responded to message with status: " + status.name());
if (context != null) {
synchronized (context) {
context.notify();
}
}
}
}
private static class MessageSender implements Runnable {
public void run() {
try {
// Initialize the simulated telemetry.
double minTemperature = 20;
double minHumidity = 60;
Random rand = new Random();
int i = 0;
while (i < 100000) {
// Simulate telemetry.
double currentTemperature = minTemperature + rand.nextDouble() * 15;
double currentHumidity = minHumidity + rand.nextDouble() * 20;
TelemetryDataPoint telemetryDataPoint = new TelemetryDataPoint();
telemetryDataPoint.temperature = currentTemperature;
telemetryDataPoint.humidity = currentHumidity;
// Add the telemetry to the message body as JSON.
String msgStr = telemetryDataPoint.serialize();
byte[] bodyClone = msgStr.getBytes(StandardCharsets.UTF_8);
Message msg = new Message(bodyClone);
// Add a custom application property to the message.
// An IoT hub can filter on these properties without access to the message body.
msg.setProperty("temperatureAlert", (currentTemperature > 30) ? "true" : "false");
msg.setMessageType(MessageType.DEVICE_TELEMETRY);
System.out.println("Sending message string: " + msgStr);
System.out.println("Sending message: " + msg);
Object lockobj = new Object();
// Send the message.
EventCallback callback = new EventCallback();
client.sendEventAsync(msg, callback, lockobj);
synchronized (lockobj) {
lockobj.wait();
}
Thread.sleep(1000);
}
} catch (InterruptedException e) {
System.out.println("Finished.");
}
}
}
public static void main(String[] args) throws IOException, URISyntaxException {
// Connect to the IoT hub.
client = new DeviceClient(connString, protocol);
client.open();
// Create new thread and start sending messages
MessageSender sender = new MessageSender();
ExecutorService executor = Executors.newFixedThreadPool(1);
executor.execute(sender);
// Stop the application.
System.out.println("Press ENTER to exit.");
System.in.read();
executor.shutdownNow();
client.closeNow();
}
}
对于 QueryString - temperatureAlert = "true" - 一切正常。但是对于查询字符串 - $body.temperature > 30 - 然后我没有收到任何消息。
解决方案
为了让 IoT 中心知道是否可以根据其正文内容路由消息,消息必须包含描述其正文内容和编码的特定标头。特别是,消息必须具有这两个标头才能在消息正文上路由才能工作:
- “应用程序/json”的内容类型
- 内容编码必须匹配以下之一:
- “UTF-8”
- “UTF-16”
- “UTF-32”
在创建 Message 对象的语法下方添加以下两行:
msg.setContentEncoding("utf-8");
msg.setContentType("application/json");
推荐阅读
- javascript - 使用Angular重定向到html中的另一个页面
- javascript - Vue 3 vue-cli,如何为 css/js 使用 CDN url?
- apache-beam - 根据偏移量或偏移量时间戳停止从 Kafka 消费的 Beam 管道
- json - 从 VUE 中的本地 json-server 检索数据
- javascript - Javascript函数返回错误的计算值
- rust - 递归构建迭代器会导致“递归不透明类型”错误
- pygame - Python 3.9.6 屏幕不会显示颜色
- html - (HTML & CSS) 我正在尝试在图像之间添加圆圈,但它们不会垂直居中
- r - 使用R比较两个excel文件
- google-apps-script - Apps 脚本 - 复制和删除超过 6 个月的行