65 wiersze
2.1 KiB
Python
65 wiersze
2.1 KiB
Python
import config
|
|
import json
|
|
import logging
|
|
import mqtt
|
|
import report
|
|
import subprocess
|
|
import time
|
|
|
|
try:
|
|
from config import APP_NAME as ROOT_LOGGER_NAME
|
|
except ImportError:
|
|
ROOT_LOGGER_NAME = 'root'
|
|
logger = logging.getLogger(ROOT_LOGGER_NAME).getChild('main')
|
|
|
|
|
|
class exec_command(mqtt.mqtt_client):
|
|
def __init__(self):
|
|
self.__block_execution__ = False
|
|
mqtt.mqtt_client.__init__(self, config.APP_NAME, config.MQTT_SERVER, 1883, config.MQTT_USER, config.MQTT_PASS)
|
|
for topic in config.EXEC_LIST:
|
|
self.add_callback(topic, self.mqtt_rx)
|
|
# Start a pseudo process
|
|
self.process = subprocess.Popen(["sleep", "0"])
|
|
|
|
def exec_command(self, cmd):
|
|
self.process = subprocess.Popen(cmd.split(" "))
|
|
|
|
def mqtt_rx(self, client, userdate, message):
|
|
payload = None
|
|
key = config.EXEC_LIST[message.topic].get('key')
|
|
data = config.EXEC_LIST[message.topic].get('data')
|
|
if key is None:
|
|
try:
|
|
payload = message.payload.decode('utf-8')
|
|
except:
|
|
logger.exception("Error decoding mqtt message")
|
|
else:
|
|
try:
|
|
payload = json.loads(message.payload)
|
|
except:
|
|
logger.exception("Error decoding json mqtt message")
|
|
else:
|
|
try:
|
|
payload = payload.get(key)
|
|
except AttributeError:
|
|
logger.exception("payload seems to be no dictionary")
|
|
if data is None or payload == data:
|
|
if self.process.poll() is None:
|
|
self.process.kill()
|
|
logger.debug("Starting execution in background...")
|
|
self.exec_command(config.EXEC_LIST[message.topic]['command'])
|
|
|
|
|
|
if __name__ == '__main__':
|
|
report.appLoggingConfigure(config.__BASEPATH__, config.LOGTARGET, ((config.APP_NAME, config.LOGLVL), ), fmt=config.formatter, host=config.LOGHOST, port=config.LOGPORT)
|
|
#
|
|
ec = exec_command()
|
|
#
|
|
while True:
|
|
time.sleep(30)
|
|
try:
|
|
ec.join()
|
|
finally:
|
|
ec.stop()
|