户手册:接入设备之连接MQTT设备
2023/2/17 4:24:05
本文主要是介绍户手册:接入设备之连接MQTT设备,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
获取模版
请在examples/mqttDeviceShifu查看模板文件。
修改配置
在examples/mqttDeviceShifu/mqtt_deploy/mqtt_edgedevice.yaml
中:
... spec: sku: "testMQTT" # 修改此值 connection: Ethernet address: 192.168.62.231:1883 # 修改此值 protocol: MQTT protocolSettings: MQTTSetting:
在examples/mqttDeviceShifu/mqtt_deploy/mqtt_deviceshifu_configmap.yaml
中:
... data: driverProperties: | driverSku: testMQTT driverImage: instructions: | instructions: # 一条命令可以订阅一个topic,如需订阅多个topic,增加命令即可 get_topicmsg1: # 修改此值 protocolPropertyList: MQTTTopic: "/test/test1" # 修改此值 get_topicmsg2: protocolPropertyList: MQTTTopic: "/test/test2" ... # 根据自己的需要可继续配置命令及对应的Topic,只需按照此格式继续添加即可
部署deviceShifu
运行下面的命令:
kubectl apply -f examples/mqttDeviceShifu/mqtt_deploy
获取设备最新的MQTT消息
在您的集群中运行下面的命令:
curl deviceshifu-mqtt/get_topicmsg1
这里get_topicmsg1
是需要查询的字段。
MQTTdeviceShifu返回的内容如下:
{"mqtt_message":"test2333","mqtt_receive_timestamp":"2022-04-29 08:57:49.9492744 +0000 UTC m=+75.407609501"}
其中mqtt_message
是设备接受到的最新字符串。mqtt_receive_timestamp
是接收到该消息的时间戳。
通过deviceShifu发布MQTT消息
在您的集群中运行下面的命令:
curl -X POST -d 'test_publish' deviceshifu-mqtt/get_topicmsg1
这里get_topicmsg1
是需要查询或发布的字段。
发布之后,再次查询MQTTdeviceShifu返回的内容如下:
{"mqtt_message":"test_publish","mqtt_receive_timestamp":"2022-04-29 08:57:59.7397692 +0000 UTC m=+75.407609501"}
本文由边无际授权发布
这篇关于户手册:接入设备之连接MQTT设备的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-05-08「布道师系列文章」解析 AutoMQ 对象存储中的文件存储格式
- 2024-05-08「布道师系列文章」小红书黄章衡:AutoMQ Serverless 基石-秒级分区迁移
- 2024-05-08AutoMQ 系统测试体系揭秘
- 2024-03-14AutoMQ 携手阿里云共同发布新一代云原生 Kafka,帮助得物有效压缩 85% Kafka 云支出!
- 2024-02-22kafka partitioner
- 2024-01-24AutoMQ生态集成 - 将数据从 AutoMQ Kafka 导入 RisingWave 数据库
- 2024-01-13消息队列面试题:为什么要使用消息队列?
- 2024-01-08"基于 XHAMQ 的消息队列系统实现"
- 2023-11-24全网最全图解Kafka适用场景
- 2023-09-19RabbitMQ 消息应答