MQTT2MySQLBridge is a project to connect a locally running broker to a MySQL database and store the messages in a database table. The project was written and tested in Python 3.
- Adjust the broker to the address you want to use:
broker_source - Add your custom filters to
filterMessage()if you want to filter messages - Adjust your credentials (uncomment if anonymous):
client_source.username_pw_set("mqtt", "IoT")- Adjust your MySQL credentials:
DatabaseHostName = 'YourHost'
DatabaseUserName = 'YourUser'
DatabasePassword = 'YourPassword'
DatabasePort = 3306-
Run the script
SetupDatabase.sqlon your database to setup the database correctly -
Add filters to the bridging like described in the
bridgeFiltering.pyfile if needed:
def filterMessage(payload, topic, qos):
"Filters the messages depending on the configuration for the attributes payload, topic and QoS. 'True' means that the message is not forwarded."
# Examples below:
if(payload == "10 %"):
print('Filtered: payload == "10 %"')
return True
if(topic == "humidity" and qos == 0):
print('Filtered: topic == "humidity" and qos == 0')
return True
if(topic == "temperature" or qos == 2):
print('Filtered: topic == "temperature" or qos == 2')
return True
#Add your filters heresudo apt-get install python3
sudo apt-get install python3-pip
sudo pip3 install paho-mqtt
sudo pip3 install pymysqlor
sudo apt-get install python3
sudo apt-get install python3-pip
sudo pip3 install -r requirements.txtpython3 bridge.py
python3 bridgeFiltering.pyhttps://gist.github.com/SeppPenner/6a5a30ebc8f79936fa136c524417761d
See the Changelog.