ThingsBoard使用规则链将设备信息转发至外部mqtt

布满荆棘的人生 2022-11-15 12:29 1132阅读 0赞

原文地址：[https://blog.csdn.net/qq\_31867231/article/details/109364561][https_blog.csdn.net_qq_31867231_article_details_109364561]

# 使用场景 #

需要将 tb 从网关接收到的设备信息保存到自己的项目中。

# 配置步骤 #

## tb 系统属性 ##

![图片][fe35469d89a1887d8ae19adf9202885a.png]

这里需要使用到规则链中属性集的 originator fields

发送者字段添加消息发送者字段值到消息元数据中将获取在映射中指定的字段值。如果指定的字段不是发起者字段的一部分，它将被忽略。

可以添加的系统属性值为 device 表中的字段，

CREATE TABLE "public"."device" (
    "id" uuid NOT NULL,
    "created_time" int8 NOT NULL,
    "additional_info" varchar COLLATE "pg_catalog"."default",
    "customer_id" uuid,
    "type" varchar(255) COLLATE "pg_catalog"."default",
    "name" varchar(255) COLLATE "pg_catalog"."default",
    "label" varchar(255) COLLATE "pg_catalog"."default",
    "search_text" varchar(255) COLLATE "pg_catalog"."default",
    "tenant_id" uuid,
    CONSTRAINT "device_pkey" PRIMARY KEY ("id"),
    CONSTRAINT "device_name_unq_key" UNIQUE ("tenant_id", "name")
    )
    ;

这里我们添加设备 id，设备区域

![图片][5bc1655805c78341b72b3a642951c37c.png]

然后从Message Type Switch 连接到系统属性

Post attributes 为设备属性数据

Post telemetry 为设备遥测数据

![图片][ab233d2f2d7d0da32a0a37772be9b019.png]

## 转换器 ##

转换器的作用是将 tb 的 json 信息转换我们想要的格式

![20210401144447689.png][]

![图片][0fc22ae6a80279cce0c0e72423d308ab.png]

return {
            msg: {
                ts: metadata['ts'],
                deviceId: metadata['id'],
                msgType: msgType,
                deviceType: metadata['deviceType'],
                deviceName: metadata['deviceName'],
                label: metadata['label'],
                msg: msg
            },
            metadata: metadata,
            msgType: msgType
        };

## 发送 mqtt ##

![图片][62e2408f562729b24659b53a0741660a.png]

添加 mqtt 模块，填写自己的 mqtt 地址以及订阅主题，这里我使用的 emqx

![图片][169d7007316ae7738d08e60c1585ac9b.png]

最终的规则链：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxNDU0OTcz_size_16_color_FFFFFF_t_70][]

我这边使用了较多的连线类型

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxNDU0OTcz_size_16_color_FFFFFF_t_70 1][]

我这边配置了emqx的用户名密码认证，需要改成basic类型，还有无认证以及证书认证等。

使用 mqttbox 测试

![20210401145032213.gif][]

可以看到 mqtt 已经可以订阅到设备信息，那么这些信息怎么使用，能干什么，就可以为所欲为了

**没有收到订阅消息？可以通过调试模式查看问题出现在哪个节点。**

## **关于调试模式：** ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxNDU0OTcz_size_16_color_FFFFFF_t_70 2][]

可以看到图中的五个节点，每个节点都可以开启调试模式，然后可以在事件里调试看到一些打印数据。如：我们在第三个节点开启调试模式：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxNDU0OTcz_size_16_color_FFFFFF_t_70 3][]

提交之后在规则链里也要提交一次，否则不生效。最终：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxNDU0OTcz_size_16_color_FFFFFF_t_70 4][]

当然事件里还有其他类型，如mqtt我们填写错误的信息：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxNDU0OTcz_size_16_color_FFFFFF_t_70 5][]

依次事件类型看过去：

![20210401145948300.png][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxNDU0OTcz_size_16_color_FFFFFF_t_70 6][]

查看错误信息：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxNDU0OTcz_size_16_color_FFFFFF_t_70 7][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxNDU0OTcz_size_16_color_FFFFFF_t_70 8][]

调试还有很多妙用，自行摸索啦，告辞！

[https_blog.csdn.net_qq_31867231_article_details_109364561]: https://blog.csdn.net/qq_31867231/article/details/109364561
[fe35469d89a1887d8ae19adf9202885a.png]: /images/20221022/630afb79939a444d9dcbf0b9f7119099.png
[5bc1655805c78341b72b3a642951c37c.png]: /images/20221022/430c9b30f40c415e82b02f4d33e3a302.png
[ab233d2f2d7d0da32a0a37772be9b019.png]: /images/20221022/5acd94dd7e224f4c87e6efe25241930c.png
[20210401144447689.png]: /images/20221022/0fc5de371bbb4a579fd7006aacf2cbd0.png
[0fc22ae6a80279cce0c0e72423d308ab.png]: /images/20221022/f52e52d85df34bbcadabb53bba1e0b7c.png
[62e2408f562729b24659b53a0741660a.png]: /images/20221022/1a7618db1be1415e9117af867d12fe8c.png
[169d7007316ae7738d08e60c1585ac9b.png]: /images/20221022/82bb13744c7c439aba337223f9599c64.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxNDU0OTcz_size_16_color_FFFFFF_t_70]: /images/20221022/8603abb03c5b4b86a853de1a7a8315dd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxNDU0OTcz_size_16_color_FFFFFF_t_70 1]: /images/20221022/5dc00826ab76442f8184ee6b3d657dab.png
[20210401145032213.gif]: /images/20221022/ab6417b2c6eb456196a912a7ae8f60bc.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxNDU0OTcz_size_16_color_FFFFFF_t_70 2]: /images/20221022/d48c66c6770340cfa151585af0f47822.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxNDU0OTcz_size_16_color_FFFFFF_t_70 3]: /images/20221022/fc961531150a46cf8e07c7d8dce1086d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxNDU0OTcz_size_16_color_FFFFFF_t_70 4]: /images/20221022/03081f85609241f1825e64bf2049d03e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxNDU0OTcz_size_16_color_FFFFFF_t_70 5]: /images/20221022/fe86f48043e94e34aa9191ad25fb6599.png
[20210401145948300.png]: /images/20221022/d81d7764ed9f4a569c213aa1e66297a3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxNDU0OTcz_size_16_color_FFFFFF_t_70 6]: /images/20221022/2e71ac9b860b4fd0b5acac91ffc65560.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxNDU0OTcz_size_16_color_FFFFFF_t_70 7]: /images/20221022/31e9fa64f9894529a5a11528a4ebce72.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxNDU0OTcz_size_16_color_FFFFFF_t_70 8]: /images/20221022/63b9b4e578d2451eafa895e0e3f37744.png