ips_mqtt2db.py File Reference

script to log via MQTTPUB generated MQTT messages into database More...

Functions
	getFileNameWithoutExtension (path)
	retrieves the filename without extension
	read_config ()
	read config from yom file
	on_connect (client, userdata, flags, rc)
	process paho mqtt connect event
	on_message (client, userdata, msg)
	process incoming paho mqtt message event

Detailed Description

script to log via MQTTPUB generated MQTT messages into database

to run adjust credentials first

Author

Date

2017-03-11

Version

0.2

Copyright

Thomas Dressler 2016-2017

How to use:

• create mysql account and database.
• Grant "Create table, Insert,update,delete,index " or simple "All" on database
• check if you can connect
• create a YAML file 'ips_mqtt2db.yml' with the needed credentials and adjust the values.

  mysql:
     host: localhost
     user: ips
     passwd: secret
     db: ips
  mqtt:
   host: localhost
   port: 1883
   topic: IPS/status/#

• install required additional pip libraries:

  paho_mqtt
  MySQL-python (python2)/ PyMySQL (python3)
  PyYAML

Function Documentation

getFileNameWithoutExtension()

getFileNameWithoutExtension

(

path

)

retrieves the filename without extension

Parameters

path

Filename

Returns

string

on_connect()

on_connect	(		client,
			userdata,
			flags,
			rc
	)

process paho mqtt connect event

Parameters

client
userdata
flags
rc

on_message()

on_message	(		client,
			userdata,
			msg
	)

process incoming paho mqtt message event

Parameters

client
userdata
msg	payload

expected payload json data format:

{'Path': 'APCUPSD Devices/Back-UPS RS 900G/Load',
'TS': 1476977860,
'UTF8Value': '25',
'VariableChanged': 1476977860,
'VariableID': 10899,
'VariableIdent': 'LoadPct',
'VariableType': 1,
'VariableUpdated': 1476977860}