diff options
Diffstat (limited to 'scripts/mqtt_listener.py')
| -rw-r--r-- | scripts/mqtt_listener.py | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/scripts/mqtt_listener.py b/scripts/mqtt_listener.py index 6e9a307..85d27a1 100644 --- a/scripts/mqtt_listener.py +++ b/scripts/mqtt_listener.py @@ -6,7 +6,7 @@ import json from datetime import datetime import paho.mqtt.client as mqtt -from common import dbi +import common mqtt_server = os.environ['el_mqtt_server'] mqtt_port = int(os.environ['el_mqtt_port']) @@ -37,8 +37,7 @@ def on_message(client, userdata, msg): else: return - dbi(sql, values, verbose=True) - + common.dbi(sql, values, verbose=True) # mqtt |