in pyscripts/docker_log_processor.py [0:0]
def __init__(self, args):
# Parse args
parser = argparse.ArgumentParser(description="Docker Log Processor")
group = parser.add_mutually_exclusive_group(required=True)
group.add_argument(
"-staticfile", action="append", nargs="+", help="filename to read from"
)
group.add_argument(
"-modulename",
action="append",
nargs="+",
help="docker modulename to read from",
)
parser.add_argument("-filterfile", nargs=1, help="filename of json filters")
arguments = parser.parse_args(args)
if arguments.staticfile:
self.process_static_log(arguments.staticfile, arguments.filterfile)
else:
self.queue = Queue()
self.logger_thread = Thread(target=self.process_queue)
self.logger_thread.start()
self.watcher_processes = []
for container_name in arguments.modulename:
print("Getting Log for: " + container_name)
new_process = Process(
target=self.get_log_from_container,
args=(container_name, self.queue),
)
new_process.start()
self.watcher_processes.append(new_process)