diff --git a/control_mqtt.py b/control_mqtt.py index c823b6c..6b54d34 100755 --- a/control_mqtt.py +++ b/control_mqtt.py @@ -41,6 +41,13 @@ class CurrentClients: stderr=subprocess.PIPE, text=True ) + ''' + for line in process.stdout: + logging.info(f"Subtask stdout: {line.strip()}") + + for line in process.stderr: + logging.error(f"Subtask stderr: {line.strip()}") + ''' self.active_clients_pids[client] = process.pid logging.info(f"Started process for {client}, PID: {process.pid}") @@ -114,6 +121,7 @@ def main(): level=args.log_level ) + auth = {'username': args.username, 'password': get_credentials(args)} cur_clients = CurrentClients(args) userdata = {'args': args, 'cur_clients': cur_clients, 'auth': auth} diff --git a/subscribe_ase_receiver.py b/subscribe_ase_receiver.py index 9ad2d1c..995b7ce 100644 --- a/subscribe_ase_receiver.py +++ b/subscribe_ase_receiver.py @@ -3,6 +3,7 @@ import argparse import requests import psycopg2 import json +import sys import os import logging @@ -111,9 +112,9 @@ def main(): args = parser.parse_args() logging.basicConfig( - format="%(asctime)s - PID: %(process)d %(levelname)8s: %(message)s ", + format="- PID: %(process)d %(levelname)8s: %(message)s ", level=args.log_level, - filename=f"/var/log/{args.client.removesuffix('_ase')}_receiver.log" + stream=sys.stderr ) init_db(args)