Azure IoT 中心中的消息路由只会导致孤立消息

Question

我正在为设备编写心跳函数。以下代码使用适用于设备的 Azure SDK 构建消息信封：

private Message constructHeartbeatEnvelope(final HeartbeatEvent heartbeat) throws JsonProcessingException {
    String jsonString = mapper.writeValueAsString(heartbeat);
    System.out.println(jsonString);
    final Message message = new Message(jsonString.getBytes(StandardCharsets.UTF_8));
    message.setProperty("type", "heartbeat");
    message.setContentTypeFinal("application/json");
    message.setExpiryTime(HEARTBEAT_INTERVAL);
    return message;
}

在该设备所属的IoT Hub中，我有以下两条路由供测试：

+-----------------+----------------+--------------------------------------+------------+---------+
|      Name       |  Data Source   |            Routing Query             |  Endpoint  | Enabled |
+-----------------+----------------+--------------------------------------+------------+---------+
| heartbeat-route | DeviceMessages | $body.type.name = 'heartbeat/device' | events-dev | true    |
| events-dev-type | DeviceMessages | $type = 'heartbeat'                  | events-dev | true    |
+-----------------+----------------+--------------------------------------+------------+---------+

邮件正文如下所示：

{
    "created": 1568104629007,
    "type": {
        "name": "heartbeat/device",
        "version": "1.0"
    },
    "origin": "iothubdeviceid",
    "content": {
        // heartbeat metadata
    },
    "originId": "S1"
}

后备路由被禁用。

events-dev 端点是一个事件中心，它有一个专门的消费者组来处理这些心跳事件。最后是一个函数应用程序，它从这个事件中心消费，并且只打印它接收到的内容的主体以用于调试目的。

但是，当我在我的 IoT 中心查看指标时，它显示零消息被路由到事件中心，并且所有发送的消息都是“孤立的”。

在内置端点下，我还添加了一个名为 heartbeats 的额外消费者组。

我尝试激活回退路由，然后使用仅接收消息的 Python SDK 中的修改示例，我连接到 IoT 中心事件中心，我可以在那里找到消息，但我无法让路由正常工作一点也不。我还看到指标中的孤立消息返回到 0，并且路由到回退的消息上升。执行此方法时，我也没有在 heartbeats 消费者组上收到任何消息，仅在 $Default 上。

我在这里做错了什么？

解决方案：

根据下面的回复，以下方法成功了：

删除 $ 以过滤用户添加的属性：

+-----------------+----------------+--------------------------------------+------------+---------+
|      Name       |  Data Source   |            Routing Query             |  Endpoint  | Enabled |
+-----------------+----------------+--------------------------------------+------------+---------+
| heartbeat-route | DeviceMessages | $body.type.name = 'heartbeat/device' | events-dev | true    |
| events-dev-type | DeviceMessages | type = 'heartbeat'                   | events-dev | true    |
+-----------------+----------------+--------------------------------------+------------+---------+

在邮件信封上手动设置内容编码：

private Message constructHeartbeatEnvelope(final HeartbeatEvent heartbeat) throws JsonProcessingException {
    String jsonString = mapper.writeValueAsString(heartbeat);
    System.out.println(jsonString);
    final Message message = new Message(jsonString.getBytes(StandardCharsets.UTF_8));
    message.setProperty("type", "heartbeat");
    message.setContentTypeFinal("application/json");
    message.setContentEncoding("utf-8"); // <---- This line
    message.setExpiryTime(HEARTBEAT_INTERVAL);
    return message;
}

尽管进行了上述修复，身体路由似乎无法正常工作

Answer 1

以下是修复：

1. 类型 = '心跳'
2. 为 utf-8 设置消息 ContentEcoding

查看更多详情here。