Skip to content
Snippets Groups Projects
Commit 1fe0507e authored by Eesaan Atluri's avatar Eesaan Atluri
Browse files

Use logging from rc_util

parent 224e63c6
No related branches found
No related tags found
6 merge requests!147Merge previous default branch feat-cod-rmq into main,!85kill nginx process running under user from login node,!51Fix acct create wait,!39WIP:Feat cod rmq,!31Feat add user reg logger,!38WIP: Feat cod rmq
...@@ -2,7 +2,7 @@ ...@@ -2,7 +2,7 @@
import json import json
import sys import sys
import dataset import dataset
import logging import rc_util
from rc_rmq import RCRMQ from rc_rmq import RCRMQ
from datetime import datetime from datetime import datetime
...@@ -10,7 +10,13 @@ from datetime import datetime ...@@ -10,7 +10,13 @@ from datetime import datetime
task = 'reg_logger' task = 'reg_logger'
# Instantiate rabbitmq object # Instantiate rabbitmq object
reg_logger = RCRMQ({'exchange': 'RegUsr', 'exchange_type': 'topic'}) rc_rmq = RCRMQ({'exchange': 'RegUsr', 'exchange_type': 'topic'})
# Parse arguments
args = rc_util.get_args()
# Logger
logger = rc_util.get_logger()# Define your callback function
# Parse arguments # Parse arguments
args = rc_util.get_args() args = rc_util.get_args()
...@@ -35,7 +41,7 @@ def log_registration(ch, method, properties, body): ...@@ -35,7 +41,7 @@ def log_registration(ch, method, properties, body):
logger.info("Start listening to queue: {}".format(task)) logger.info("Start listening to queue: {}".format(task))
# Start consuming messages from queue with callback function # Start consuming messages from queue with callback function
reg_logger.start_consume({ rc_rmq.start_consume({
'queue': task, 'queue': task,
'routing_key': "create.*", 'routing_key': "create.*",
'cb': log_registration 'cb': log_registration
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment