# MQTT input to MySQL

**URL:** <https://discourse.nodered.org/t/mqtt-input-to-mysql/33118>\
**Category:** General\
**Created:** [20 September 2020 16:00 UTC](https://discourse.nodered.org/t/mqtt-input-to-mysql/33118 "2020-09-20T16:00:19Z")\
**Posts on this page:** 6\
**Page:** 1

<div class="post-metadata">

**Author:** ![topche](https://sea2.discourse-cdn.com/flex026/user_avatar/discourse.nodered.org/topche/32/28879_2.png) [@topche](https://discourse.nodered.org/u/topche)\
**Post date:** [20 September 2020 16:00 UTC](https://discourse.nodered.org/t/mqtt-input-to-mysql/33118/1 "2020-09-20T16:00:19Z")

</div>

I just want to clarify, that i'm completely new in Node Red.  
Hello, i have my project with NodeMCU+BME280+DS18B20 and tasmota fimware installed nad MQTT brocker.  
So I have this input on my MQTT comming:

```auto
{"Time":"2020-09-20T16:57:06","DS18B20":{"Id":"3C01B5568855","Temperature":24.5},"BME280":{"Temperature":25.6,"Humidity":26.2,"DewPoint":4.8,"Pressure":942.5},"PressureUnit":"hPa","TempUnit":"C"}

```

and need to parse them, formatting and puting in MySQL.

Can I ask you to help me , how to read and have temperature from my DS18B20 sensor and Temperature and Humidity of my BME280 sensor and after that to format them in suitable format for MySQL.

Thank you in advance.

---

<div class="post-metadata">

**Author:** ![mudwalker](https://avatars.discourse-cdn.com/v4/letter/m/47e85d/32.png) [@mudwalker](https://discourse.nodered.org/u/mudwalker)\
**Post date:** [20 September 2020 16:16 UTC](https://discourse.nodered.org/t/mqtt-input-to-mysql/33118/2 "2020-09-20T16:16:00Z")

</div>

Hi, I have just set up my MQTT Sensor.

My flow recieves the data via MQTT and then (in my case) I convert it to a Javascript object before splitting off all of the messages using a function. Once the messages are broken up into their respective message parts, they are then each passed on to the Database, in this case InfluxDB.

The Debug Node is your friend here, you need to check all messages (not just msg.payload) and then see how they can be split up.

HTH

Colin

---

<div class="post-metadata">

**Author:** ![topche](https://sea2.discourse-cdn.com/flex026/user_avatar/discourse.nodered.org/topche/32/28879_2.png) [@topche](https://discourse.nodered.org/u/topche)\
**Post date:** [20 September 2020 18:24 UTC](https://discourse.nodered.org/t/mqtt-input-to-mysql/33118/3 "2020-09-20T18:24:05Z")

</div>

I did it! And now it is working.

---

<div class="post-metadata">

**Author:** ![topche](https://sea2.discourse-cdn.com/flex026/user_avatar/discourse.nodered.org/topche/32/28879_2.png) [@topche](https://discourse.nodered.org/u/topche)\
**Post date:** [20 September 2020 18:26 UTC](https://discourse.nodered.org/t/mqtt-input-to-mysql/33118/4 "2020-09-20T18:26:39Z")

</div>

```auto
[{"id":"a1e9ebca.50c5d8","type":"tab","label":"dht2mysql","disabled":false,"info":""},{"id":"61361dea.7dc934","type":"mqtt in","z":"a1e9ebca.50c5d8","name":"DS18B20+BME280","topic":"tele/NodeMCU_Ds18b20_10BD3B/SENSOR","qos":"0","datatype":"auto","broker":"a839e467.aaa5f8","x":220,"y":300,"wires":[["179f71a4.be527e"]]},{"id":"37275d81.78e4f2","type":"debug","z":"a1e9ebca.50c5d8","name":"","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"payload","targetType":"msg","statusVal":"","statusType":"auto","x":590,"y":240,"wires":[]},{"id":"179f71a4.be527e","type":"json","z":"a1e9ebca.50c5d8","name":"","property":"payload","action":"","pretty":false,"x":410,"y":300,"wires":[["37275d81.78e4f2","975e9b0d.3965d8"]]},{"id":"975e9b0d.3965d8","type":"function","z":"a1e9ebca.50c5d8","name":"","func":"var ds_temp = { payload: msg.payload.DS18B20.Temperature };\nvar bme_temp = { payload: msg.payload.BME280.Temperature };\nvar bme_humidity = { payload: msg.payload.BME280.Humidity };\nmsg.topic = \"INSERT into alibaba (time,location,temp,humidity) values (now(),'node-red','\" + msg.payload.BME280.Temperature +\"','\" + msg.payload.BME280.Humidity + \"');\"\nreturn msg;","outputs":1,"noerr":0,"initialize":"","finalize":"","x":670,"y":400,"wires":[["78a078ba.30f0a8","95f87265.ea439"]]},{"id":"78a078ba.30f0a8","type":"debug","z":"a1e9ebca.50c5d8","name":"","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"topic","targetType":"msg","statusVal":"","statusType":"auto","x":870,"y":400,"wires":[]},{"id":"95f87265.ea439","type":"mysql","z":"a1e9ebca.50c5d8","mydb":"93023f05.61d9e","name":"","x":880,"y":340,"wires":[[]]},{"id":"a839e467.aaa5f8","type":"mqtt-broker","z":"","name":"","broker":"localhost","port":"1883","clientid":"","usetls":false,"compatmode":true,"keepalive":"60","cleansession":true,"birthTopic":"","birthQos":"0","birthPayload":"","closeTopic":"","closePayload":"","willTopic":"","willQos":"0","willPayload":""},{"id":"93023f05.61d9e","type":"MySQLdatabase","z":"","name":"","host":"192.168.1.101","port":"3306","db":"temp_izmer","tz":""}]

```

---

<div class="post-metadata">

**Author:** ![mudwalker](https://avatars.discourse-cdn.com/v4/letter/m/47e85d/32.png) [@mudwalker](https://discourse.nodered.org/u/mudwalker)\
**Post date:** [20 September 2020 19:05 UTC](https://discourse.nodered.org/t/mqtt-input-to-mysql/33118/5 "2020-09-20T19:05:59Z")

</div>

Excellent!

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/flex026/uploads/nodered/original/1X/d073cd938eafa2e558d7c2cd59003b3ef4963033.png) [@system](https://discourse.nodered.org/u/system)\
**Post date:** [19 November 2020 19:06 UTC](https://discourse.nodered.org/t/mqtt-input-to-mysql/33118/6 "2020-11-19T19:06:06Z")

</div>

This topic was automatically closed 60 days after the last reply. New replies are no longer allowed.