开发者社区

文档建议反馈控制台

最新优惠活动

文章/答案/技术大牛

发布

如何将MQTT主题数据传递给Node-Red上的Postgres

MQTT是一种轻量级的消息传输协议，常用于物联网设备之间的通信。Node-Red是一个基于流程编程的工具，用于连接硬件设备、API和在线服务。PostgreSQL是一种开源的关系型数据库管理系统。

要将MQTT主题数据传递给Node-Red上的PostgreSQL，可以按照以下步骤进行操作：

在Node-Red中安装MQTT节点：打开Node-Red的编辑界面，点击右上角的菜单按钮，选择"Manage palette"。在"Palette"选项卡中，搜索并安装"node-red-contrib-mqtt-broker"节点。
配置MQTT节点：将MQTT节点拖拽到编辑界面中，并双击打开配置窗口。在配置窗口中，点击"Add new mqtt-broker"按钮，填写MQTT服务器的连接信息，包括主机名、端口号、用户名和密码等。点击"Add"按钮保存配置。
配置PostgreSQL节点：将PostgreSQL节点拖拽到编辑界面中，并双击打开配置窗口。在配置窗口中，填写PostgreSQL数据库的连接信息，包括主机名、端口号、数据库名、用户名和密码等。点击"Add"按钮保存配置。
连接MQTT和PostgreSQL节点：将MQTT节点和PostgreSQL节点通过连线连接起来。点击MQTT节点的输出端口，拖动连线到PostgreSQL节点的输入端口。
配置数据转换：在连线上双击打开配置窗口，选择"JSON"作为数据格式。这样，当MQTT节点接收到消息时，会将消息转换为JSON格式，并传递给PostgreSQL节点。
配置数据插入：在PostgreSQL节点的配置窗口中，选择"Insert"操作，并指定要插入数据的表名和字段名。可以根据需要进行进一步的配置，如设置数据类型、映射关系等。
保存并部署：点击编辑界面右上角的"Deploy"按钮，保存并部署流程。

现在，当MQTT主题上有数据发布时，Node-Red将会接收到数据，并将其转换为JSON格式后插入到PostgreSQL数据库中。

腾讯云相关产品推荐：

MQTT Broker：腾讯云物联网通信（IoT Hub）提供了MQTT Broker服务，用于支持设备与云端的双向通信。详情请参考：腾讯云物联网通信（IoT Hub）
云数据库 PostgreSQL：腾讯云提供了云数据库 PostgreSQL 服务，可用于存储和管理数据。详情请参考：云数据库 PostgreSQL
云服务器（CVM）：腾讯云提供了云服务器服务，可用于部署和运行Node-Red等应用程序。详情请参考：云服务器（CVM）

页面内容是否对你有帮助？

有帮助

没帮助

相关·内容

如何在Ubuntu 18.04上安装和保护Mosquitto MQTT Messaging Broker

介绍 MQTT是一种机器到机器的消息传递协议，旨在为“物联网”设备提供轻量级的发布/订阅通信。它通常用于地理跟踪车队，家庭自动化，环境传感器网络和公用事业规模数据收集。...在新终端中，用于mosquitto_sub订阅测试主题： mosquitto_sub -h localhost -t test -h用于指定MQTT服务器的主机名，并且-t指定主题名称。...MQTT在websockets上没有官方的标准化端口，但是8083最常见。保存并退出该文件，然后重新启动Mosquitto。...Node-RED是一个基于浏览器的图形界面，用于将物联网“连接”在一起。您将一个节点的输出拖动到另一个节点的输入，并可以通过过滤器，各种协议之间，数据库等信息路由信息。...Node-RED非常支持MQTT。该ESP8266是一种廉价的无线微控制器MQTT。您可以连接并发布温度数据到主题中，或者可能订阅气压主题并在风暴来临时发出蜂鸣声！

8.5K1 0

如何在Ubuntu上搭建MQTT服务器

介绍 MQTT(消息队列遥测传输)是ISO 标准下基于发布/订阅范式的消息协议。它工作在 TCP/IP协议族上，是为硬件性能低下的远程设备以及网络状况糟糕的情况下而设计的发布/订阅型消息协议。...mosquitto包附带了一些MQTT客户端命令行。我们将使用其中一个订阅代理上的主题。主题是您发布消息并订阅的标签。...在新的终端中，使用mosquitto_sub订阅测试主题： mosquitto_sub -h localhost -t test -h用于指定MQTT服务器的主机名，-t是主题名。...MQTT在websockets上没有官方标准化端口，但8083是最常见的。保存并退出文件，然后重新启动Mosquitto。...您可以将一个节点的输出拖到另一个节点的输入中，并可以通过筛选器、不同协议之间的信息路由到数据库，等等。MQTT得到了Node-red的很好的支持.

13.1K1 3

【开源视频联动物联网平台】写一个物联网项目捐献给Dromara组织

协议支持集成emqx5.0 mqtt消息中间件,支持MQTT (3.1、3.1.1和5.0)等协议标准视频监控协议支持集成ZLMediaKit流媒体服务器，支持GB28181国标协议，支持RTSP...,RTMP,RTP等流媒体协议，支持海康威视，大华等主流监控设备主流modbus,PLC协议支持集成ModbusTCP服务器和ModbusRTU解码器，支持主流工控设备数据上报方式，支持MQTT透传...,TCP透传，ModbusTCP等方式，可对接主流PLC设备物模型规范有标准的物模型字段，根据属性，功能，事件来处理设备业务，支持灵活的key-value编码解析消息编码管理 key-value编码可自定义调整...细粒度的时序数据库记录集成TDengine时序数据库，可记录每个设备的属性和事件历史数据，可进行大数据处理和展示更加灵活的规则引擎集成 node-red + liteflow 框架，作为业务解耦核心组件...集成Forest框架，高层的、极简的轻量级HTTP调用API框架。

2261 0

如何在CentOS上安装Mosquitto服务器

介绍 MQTT(消息队列遥测传输)是ISO 标准下基于发布/订阅范式的消息协议。它工作在 TCP/IP协议族上，是为硬件性能低下的远程设备以及网络状况糟糕的情况下而设计的发布/订阅型消息协议。...mosquitto包附带了一些MQTT客户端命令行。我们将使用其中一个订阅代理上的主题。主题是您发布消息并订阅的标签。...在新的终端中，使用mosquitto_sub订阅测试主题： mosquitto_sub -h localhost -t test -h用于指定MQTT服务器的主机名，-t是主题名称。...MQTT在websockets上没有官方标准化端口，但8083是最常见的。保存并退出该文件，然后重新启动Mosquitto。...您可以将一个节点的输出拖到另一个节点的输入中，并可以通过筛选器、不同协议之间的信息路由到数据库，等等。MQTT得到了Node-red的很好的支持.

12.7K1 1

物联网入门：搭建MQTT服务器

导言 MQTT(消息队列遥测传输)是ISO 标准下基于发布/订阅范式的消息协议。它工作在 TCP/IP协议族上，是为硬件性能低下的远程设备以及网络状况糟糕的情况下而设计的发布/订阅型消息协议。...mosquitto包附带了一些MQTT客户端命令行。我们将使用其中一个订阅代理上的主题。主题是您发布消息并订阅的标签。...在新的终端中，使用mosquitto_sub订阅测试主题： mosquitto_sub -h localhost -t test -h用于指定MQTT服务器的主机名，-t是主题名。...OwnTracks将定期向您的MQTT服务器报告位置信息，然后您可以将其存储并显示在地图上，或者根据您的位置创建警报和激活物联网硬件。 Node-RED是一个基于浏览器的图形界面，用于“连接”物联网。...您可以将一个节点的输出拖到另一个节点的输入中，并可以通过筛选器、不同协议之间的信息路由到数据库，等等。MQTT得到了Node-red的很好的支持.

31.1K13 6

开源免费的物联网网关 IoT Gateway

概述物联网网关，也被称为IOT网关，是一种至关重要的网络设备。在物联网系统中，它承担着连接和控制各种设备的重要任务，将这些设备有效地连接到云端、本地服务器或其他设备上。...多协议网关现代经济学理论指出，企业本质上是类似于“多协议网关”的存在，这种网关支持多种通信协议和标准，使得使用不同协议的设备能够实现无缝连接和通信。...Node-RED Node-RED 是一款以流为基础的可视化物联网编程工具，最初由IBM的新兴技术服务团队倾力打造，现归属OpenJS基金会。...通过Node-RED，您可以轻松实现物联网设备的编程和自动化控制，因为它支持多种协议，如MQTT、HTTP等。来自官网 3.5....同时，它也是一个开源的MQTT broker，支持MQTT协议，并可作为物联网网关，实现数据传输和转换功能。 3.6.

1.1K1 0

0-STM32F407+ESP8266基本控制篇(自建物联网平台)-整体运行测试-微信小程序使用APUConfig配网绑定ESP8266,并通过MQTT实现远程通信控制

APP获取设备的MAC地址后,APP发布的主题是: user/设备的MAC APP订阅的主题是: device/设备的MAC APP和设备的发布和订阅的主题相对应,APP和设备的消息发给MQTT服务器以后...6.在连接成功回调函数中订阅主题,组合发布的主题 7.连接成功MQTT服务器以后解析服务器下发的MQTT数据是下面的函数把接收的mqtt数据交给这个函数,函数内部解析之后会调用相应的回调函数...把打包好的MQTT协议数据提取出来并发送给服务器的地方封装的MQTT程序支持透传的模组和非透传的模组,用户只需要按照说明进行操作....当前的模组是工作在非透传模式, 发送数据首先发送 AT+CIPSEND=xxxxxx 等待模组返回 > 然后再把实际数据发送给模组发送成功以后模组会返回 SEND OK 11,缓存管理是使用的我编写的...,携带着设备的MAC地址信息跳转到设备控制页面 18,控制页面在onLoad函数里面接收跳转的数据,并在里面设置MQTT回调函数 19.在定时器里订阅主题 20.在MQTT接收回调函数中接收处理数据

7641 0

0-STM32F407+ESP8266基本控制篇(自建物联网平台)-整体运行测试-Android使用APUConfig配网绑定ESP8266,并通过MQTT实现远程通信控制

APP获取设备的MAC地址后,APP发布的主题是: user/设备的MAC APP订阅的主题是: device/设备的MAC APP和设备的发布和订阅的主题相对应,APP和设备的消息发给MQTT服务器以后...,不停的使用udp把路由器信息发给模组模组接收到路由器信息以后把自身的MAC地址发给APP 2,启动绑定 3.注意按常理来讲,应该是模块获取到路由器信息,然后连接上之后再把自己的MAC传递给APP...6.在连接成功回调函数中订阅主题,组合发布的主题 7.连接成功MQTT服务器以后解析服务器下发的MQTT数据是下面的函数把接收的mqtt数据交给这个函数,函数内部解析之后会调用相应的回调函数...把打包好的MQTT协议数据提取出来并发送给服务器的地方封装的MQTT程序支持透传的模组和非透传的模组,用户只需要按照说明进行操作....当前的模组是工作在非透传模式, 发送数据首先发送 AT+CIPSEND=xxxxxx 等待模组返回 > 然后再把实际数据发送给模组发送成功以后模组会返回 SEND OK 11,缓存管理是使用的我编写的

7262 0

0-CH32V307+ESP8266基本控制篇(自建物联网平台)-整体运行测试-微信小程序使用APUConfig配网绑定ESP8266,并通过MQTT实现远程通信控制

APP获取设备的MAC地址后,APP发布的主题是: user/设备的MAC APP订阅的主题是: device/设备的MAC APP和设备的发布和订阅的主题相对应,APP和设备的消息发给MQTT...6.在连接成功回调函数中订阅主题,组合发布的主题 7.连接成功MQTT服务器以后解析服务器下发的MQTT数据是下面的函数把接收的mqtt数据交给这个函数,函数内部解析之后会调用相应的回调函数...把打包好的MQTT协议数据提取出来并发送给服务器的地方封装的MQTT程序支持透传的模组和非透传的模组,用户只需要按照说明进行操作....当前的模组是工作在非透传模式, 发送数据首先发送 AT+CIPSEND=xxxxxx 等待模组返回 > 然后再把实际数据发送给模组发送成功以后模组会返回 SEND OK 11,缓存管理是使用的我编写的...,携带着设备的MAC地址信息跳转到设备控制页面 18,控制页面在onLoad函数里面接收跳转的数据,并在里面设置MQTT回调函数 19.在定时器里订阅主题 20.在MQTT接收回调函数中接收处理数据

7664 0

0-CH32V307+ESP8266基本控制篇(自建物联网平台)-整体运行测试-Android使用APUConfig配网绑定ESP8266,并通过MQTT实现远程通信控制

APP获取设备的MAC地址后,APP发布的主题是: user/设备的MAC APP订阅的主题是: device/设备的MAC APP和设备的发布和订阅的主题相对应,APP和设备的消息发给MQTT服务器以后...,不停的使用udp把路由器信息发给模组模组接收到路由器信息以后把自身的MAC地址发给APP 2,启动绑定 3.注意按常理来讲,应该是模块获取到路由器信息,然后连接上之后再把自己的MAC传递给APP...6.在连接成功回调函数中订阅主题,组合发布的主题 7.连接成功MQTT服务器以后解析服务器下发的MQTT数据是下面的函数把接收的mqtt数据交给这个函数,函数内部解析之后会调用相应的回调函数...把打包好的MQTT协议数据提取出来并发送给服务器的地方封装的MQTT程序支持透传的模组和非透传的模组,用户只需要按照说明进行操作....当前的模组是工作在非透传模式, 发送数据首先发送 AT+CIPSEND=xxxxxx 等待模组返回 > 然后再把实际数据发送给模组发送成功以后模组会返回 SEND OK 11,缓存管理是使用的我编写的

8213 0

Node-RED 物联网应用开发的十大特性有哪些？

5.多种数据格式支持 Node-RED支持多种常见的数据格式（包括JSON、XML、CSV等），方便用户在流程中进行数据的处理和转换。...而这些数据格式基本上在大多数其他系统中都是通用的，特别是JSON格式。...、Websocket、MQTT等），可以方便地与不同类型的设备和服务进行交互。...在不同的硬件上运行Node-RED保持了操作的一致性，使用方式没有变化，可以方便地成形项目化和产品化的能力。...前端工程师可以独立完成物联网后台的数据采集和控制，自行通过 HTTP、WebSocket、MQTT（消息队列遥测传输）等常用的协议来对接前端界面，实现完整应用。

2640 0

2-CH579M+ESP8266(WiFi)基本控制篇-整体运行测试-Android使用APUConfig配网绑定ESP8266,并通过MQTT和单片机CH579M实现远程通信控制

设备连接上MQTT服务器以后,设备订阅的主题是: user/设备的MAC地址设备发布的主题是: device/设备的MAC地址 APP获取设备的MAC地址后,APP发布的主题是: user/设备的...MAC地址 APP订阅的主题是: device/设备的MAC地址 APP和设备的发布和订阅的主题相对应,APP和设备的消息发给MQTT服务器以后,MQTT服务器就为各自的消息互相转发....MAC传递给APP,然后实现绑定..... 4.先使用TCP连接上TCP服务器(MQTT服务器就是TCP服务器嘛) 控制连接服务器使用的是 ConfigModuleNoBlock 框架注意哈连接上TCP以后设置为了透传, 以后单片机串口发送的数据就会直接通过模组发到服务器...,此函数便会调用上面注册的连接成功回调函数 6.在连接成功回调函数中订阅主题,发布消息 7.连接成功MQTT服务器以后解析MQTT数据是下面的函数把数据交给这个函数,函数内部解析之后会调用相应的回调函数

4913 0

为了实现上网自由，我做了一个多功能串口服务器

串口服务器网上也有相关的产品售卖，虽然不知他们的控制原理，但是对我来说只需要将串口数据发送到V853上，通过它进行数据解析后集中通过以太网接口发送出去就实现了串口服务器和路由功能。...软件设计需要在linux系统上安装Node-Red软件，这个软件是一个图形化编程编辑界面，通过安装相对应的节点就可以实现想要的功能。...例如串口功能，MQTT功能，TCP功能等必要的组件都可以安装实现，只需要设置需要参数就可以完成相关功能，同时还可以进行数据解析，并通过Dashboard数据可视化界面做上位机显示到显示屏上面，摄像头的调用可以使用里面的组件去调用...，可以说node-red可以轻松实现串口数据转以太网，实现任何一个串口设备都可以轻松连接到服务器。...如下图就是各个节点功能的使用案例。所以解决串口和无线有线的连接问题，就可以实现数据交互的服务器。外网如果想查看上位机界面，因为它是网页版，所以通过透传的方式就可以远程打开查看这个网页。

2051 0

2-CH579M+ESP8266(WiFi)基本控制篇-整体运行测试-微信小程序使用APUConfig配网绑定ESP8266,并通过MQTT和单片机CH579M实现远程通信控制

5.点击设备进入设备控制页面注:开发板上并没有温湿度,是自己写的一个随机的数发上来的注:APP的控制是控制的这个小灯(已经被底板遮挡了) 整体说明整个程序就是利用MQTT服务器实现微信小程序和设备之间通信...3,绑定时快闪led 4.注意按常理来讲,应该是模块获取到路由器信息,然后连接上之后再把自己的MAC传递给APP,然后实现绑定..... 4.先使用TCP连接上TCP服务器(MQTT服务器就是TCP服务器嘛) 控制连接服务器使用的是 ConfigModuleNoBlock 框架注意哈连接上TCP以后设置为了透传, 以后单片机串口发送的数据就会直接通过模组发到服务器...,此函数便会调用上面注册的连接成功回调函数 6.在连接成功回调函数中订阅主题,发布消息 7.连接成功MQTT服务器以后解析MQTT数据是下面的函数把数据交给这个函数,函数内部解析之后会调用相应的回调函数...,携带着设备的MAC地址信息跳转到设备控制页面 17,控制页面在onLoad函数里面接收跳转的数据,并在里面设置MQTT回调函数 18.在定时器里订阅主题 19.在MQTT接收回调函数中接收处理数据

5882 1

ESP8266转RS485RS232TTL控制板-控制板实现MQTT通信,485,232,TTL透传(支持断线重连)

说明这节测试一下使用控制板连接MQTT服务器,并做RS485/RS232/TTL数据透传. 具体实现什么功能用户可以在这个基础上修改....MQTT服务器填写,然后点击连接 9,调试助手上发布和订阅的主题根据自己的设备打印的日志进行修改 9,然后点击订阅 10,使用调试助手发送消息给控制板,用户会在RS485口上收到数据 11,使用...RS485给控制板发送数据,数据将会转发到MQTT调试助手上 12,用户也可以测试下RS232/TTL,和上面485的一样,都是透传断线重连测试这个用户测试哈, 用户可以断路由器,或者主动关闭MQTT...程序说明 1,MQTT配置模组使用MAC地址作为MQTT的client_id; 订阅的主题为 user/模组的MAC地址; 发布的主题为 device/模组的MAC地址; 2,MQTT接收的数据通过...RS485或者RS232输出 3,心跳包处理 4,RS485/RS232/TTL接收的数据发送到MQTT 5,其它 arduino提供的这个mqtt包不太好,MQTT的通信频率至少150ms .

1.4K2 0

2-STM32+ESP8266+AIR202基本控制篇-整体运行测试-APP使用APUConfig配网绑定ESP8266,并通过MQTT和ESP8266实现远程通信控制

4.注意按常理来讲,应该是模块获取到路由器信息,然后连接上之后再把自己的MAC传递给APP,然后实现绑定....6.在连接成功回调函数中订阅主题,发布消息 ? 7.连接成功MQTT服务器以后解析MQTT数据是下面的函数把数据交给这个函数,函数内部解析之后会调用相应的回调函数 ?...9.发送温湿度数据 ? 10.提示只要是连接上MQTT了,用户只需要在任意地方调用订阅主题和发布消息就可以....用户调用其api函数所打包的数据会存储在mqtt内部缓存管理里面,然后内部自动把数据通过tcp发送出去. 缓存管理是使用的我编写的 BufferManage ? 订阅主题 ? ? ? 发布消息 ?...关于下面的 mymqtt.timer_out_send = 0; 这个是预防有的模块发送数据之后需要等待,按照提示修改就可以 wifi模块透传模式下每条数据的时间间隔需要保持在20ms以上,所以我直接设置的

6923 0

智能边缘网关

本项目旨在以“工业 4.0”理念为核心，为实现对辊弯成形制件质量的稳健控制，在精密电子万能材料试验机基础上，增加高温试验等装置；以及高精度扭矩传感器以及辊弯成形工艺设计软件，实现对不同温度、反复拉伸加载路径下超高强钢各向异性变形行为的精确描述...图片系统结构安装系统智能网关一般安装有Linux系统，能够进行数据的接收、边缘计算及上传等。...将系统刷入emmc：我们在串口工具中输入 armbian-config 指令，打开系统配置界面，具体如图3所示：图片监听串口数据我们在智能网关中搭建node-red开发环境，通过MQTT节点将底层数据转发到物联网平台...附：node-red不仅能够稳定可靠的接收底层硬件发送的数据，还极大的简化了物联网项目的开发难度，大大的加快项目进度，其中，node-red开发框架如下图所示：图片附件串口监听程序所用的语言框架有多种选择方案...，例如：1、采用python pyserial模块监听智能网关的端口，将嵌入式硬件发送的serial 数据提取出来；2.

1.1K1 0

3个适合初学者的物联网框架

截至2016年，有超过300个物联网平台可供选择，集成物联网解决方案的成本飙升，不断增长的IP地址设备网络使我们能够连接到天空中的大数据云。...所有这些共享的一些共性是它们是开源的，专为集成开发人员设计，并且与MQTT，CoaP，REST和其他人一起使用。它们都可以部署在“边缘”，它们的可扩展API提供定制。...Kura确实有一个Web UI，用于配置连接到网络的协议和设备，还包括数据和云服务选项以及其他I / O集成。使用具有在线/离线模式的多服务网关，可以管理应用程序和网络连接。...Node-RED 与Kura不同，Node-RED是一种可视化工具，用于连接物联网连接并简单地集成它们。...Flogo由Golang提供支持，也是一个易于安装和使用的可视化工具，并使用BSD风格的许可证。虽然它不像Node-RED那么老，但Flogo的零依赖模型允许在设备上共享轻量级二进制文件。

2.9K3 0

2-STM32+ESP8266+AIR202基本控制篇-整体运行测试-微信小程序使用APUConfig配网绑定ESP8266,并通过MQTT和ESP8266实现远程通信控制

4.注意按常理来讲,应该是模块获取到路由器信息,然后连接上之后再把自己的MAC传递给APP,然后实现绑定....6.在连接成功回调函数中订阅主题,发布消息 ? 7.连接成功MQTT服务器以后解析MQTT数据是下面的函数把数据交给这个函数,函数内部解析之后会调用相应的回调函数 ?...9.发送温湿度数据 ? 10.提示只要是连接上MQTT了,用户只需要在任意地方调用订阅主题和发布消息就可以....用户调用其api函数所打包的数据会存储在mqtt内部缓存管理里面,然后内部自动把数据通过tcp发送出去. 缓存管理是使用的我编写的 BufferManage ? 订阅主题 ? ? ? 发布消息 ?...关于下面的 mymqtt.timer_out_send = 0; 这个是预防有的模块发送数据之后需要等待,按照提示修改就可以 wifi模块透传模式下每条数据的时间间隔需要保持在20ms以上,所以我直接设置的

9602 0

2-CH579M+(Air724UG,4G)物联网开发-移植单片机MQTT包,实现CH579M+Air724UG(4G)连接MQTT服务器

和MQTT服务器通信实质上就是TCP通信,只不过数据格式要按照MQTT规定....大家伙要先准备好已经实现控制模组实现TCP通信的程序我也准备了两份(分别是透传版和非透传版的TCP连接通信程序) 先来看透传版的移植过程 1.首先打开透传版TCP程序,了解一下我是使用的我封装的...TCP服务器的函数我是使用的串口0和模组通信,而且还是透传模式;所以我就直接使用串口0发送数据就可以这个地方其实是把缓存里面MQTT打包好的协议数据发给服务器....在主循环里写上轮训发送MQTT连接协议程序连接上TCP但是没有连接上MQTT,每隔一段时间发送一次连接协议关于各个参数函数 8.在处理串口接收的数据里面加上处理MQTT连接消息提示:判断上是连接消息之后...接收的数据程序 12.订阅主题只要是连接上MQTT服务器了,从哪里调用订阅函数都可以.一般是在连接回调里面调用; 假设订阅主题为topic 测试 13.接收消息如果内存允许的话建议使用拷贝数据的形式

9033 0

点击加载更多

扫码

添加站长进交流群

领取专属 10元无门槛券

手把手带您无忧上云

扫码加入开发者社群

相关资讯

热门标签

活动推荐

运营活动

活动名称

广告关闭