Skip to content
Snippets Groups Projects

Fix user reg logger

Merged Bo-Chun Chen requested to merge github/fork/diedpigs/fix-reg-logger into feat-cod-rmq
1 file
+ 3
3
Compare changes
  • Side-by-side
  • Inline
@@ -19,14 +19,14 @@ args = rc_util.get_args()
logger = rc_util.get_logger()
# Open registry table in DB
db = dataset.connect("sqlite:///reg_logger.db")
db = dataset.connect("sqlite:///.agent_db/reg_logger.db")
account_req_table = db["registry"]
# Define registration logger callback
def log_registration(ch, method, properties, body):
account_req = json.loads(body)
account_req["req_time"] = (datetime.now(),)
account_req["req_time"] = datetime.now()
account_req_table.insert(account_req)
logger.info("logged account request for %s", account_req["username"])
@@ -37,5 +37,5 @@ logger.info("Start listening to queue: {}".format(task))
# Start consuming messages from queue with callback function
rc_rmq.start_consume(
{"queue": task, "routing_key": "create.*", "cb": log_registration}
{"queue": task, "routing_key": "request.*", "cb": log_registration}
)
Loading