diff --git a/file_writer/launch.py b/file_writer/launch.py new file mode 100644 index 00000000..03c7761b --- /dev/null +++ b/file_writer/launch.py @@ -0,0 +1,31 @@ +import argparse +import logging +import threading + +from bluekafka_utils import RedisConnector, ServiceConfig + +from file_writer import FileWriterManager + +parser = argparse.ArgumentParser(formatter_class=argparse.ArgumentDefaultsHelpFormatter) +parser.add_argument( + "--config", + default="", + help="path to the config file", +) +clargs = parser.parse_args() +config_path = clargs.config + +config = ServiceConfig(config_path) + +logging.basicConfig(filename="scan_bundler.log", level=logging.INFO, filemode="w+") +logging.getLogger("kafka").setLevel(50) +logging.getLogger().addHandler(logging.StreamHandler()) + +sb = FileWriterManager(config.redis, RedisConnector, config.scibec) + +try: + event = threading.Event() + logging.info("Started FileWriter") + event.wait() +except KeyboardInterrupt as e: + sb.shutdown() diff --git a/file_writer/requirements.txt b/file_writer/requirements.txt new file mode 100644 index 00000000..a61094fb --- /dev/null +++ b/file_writer/requirements.txt @@ -0,0 +1,6 @@ +redis +msgpack +pyyaml +typeguard +requests +h5py