23 lines
517 B
Python
23 lines
517 B
Python
import pickle
|
|
|
|
from flask_redis import Redis
|
|
from dse_shared_libs.message_broker_wrapper import MBWrapper
|
|
|
|
|
|
class EventLogger:
|
|
redis: Redis
|
|
|
|
def __init__(self, redis):
|
|
self.redis = redis
|
|
|
|
@staticmethod
|
|
def log(msg):
|
|
try:
|
|
print("{}".format(pickle.loads(msg)))
|
|
except Exception as e:
|
|
print("Could not unpickle [{}]: {}", msg, e)
|
|
|
|
def setup_msq_queue(self):
|
|
mb = MBWrapper(exchange_name='logger', callback=self.log)
|
|
mb.setup_receiver()
|