Skip to content
Snippets Groups Projects
Commit d90f8ebb authored by Sven Mäder's avatar Sven Mäder :speech_balloon:
Browse files

Change log severity for some output

parent 8b348f4b
No related branches found
No related tags found
1 merge request!12Deltalogparse
...@@ -176,7 +176,9 @@ def log_action(action, entry): ...@@ -176,7 +176,9 @@ def log_action(action, entry):
if not action == 'skip': if not action == 'skip':
log.debug('entry:') log.debug('entry:')
log.debug(pprint.pformat(entry, indent=1)) log.debug(pprint.pformat(entry, indent=1))
log.info('{}: {} {}'.format(action, req_type, req_dn)) log.info('{}: {} {}'.format(action, req_type, req_dn))
else:
log.debug('{}: {} {}'.format(action, req_type, req_dn))
def write(entry): def write(entry):
...@@ -207,7 +209,7 @@ def sleep(start_time): ...@@ -207,7 +209,7 @@ def sleep(start_time):
elapsed_time = current_time - start_time elapsed_time = current_time - start_time
sleep_time = update_every - elapsed_time sleep_time = update_every - elapsed_time
log.info('runtime {0:.3f}s, sleeping {1:.3f}s'.format(elapsed_time, sleep_time)) log.debug('runtime {0:.3f}s, sleeping {1:.3f}s'.format(elapsed_time, sleep_time))
if sleep_time > 0: if sleep_time > 0:
time.sleep(sleep_time) time.sleep(sleep_time)
...@@ -224,7 +226,7 @@ def main(): ...@@ -224,7 +226,7 @@ def main():
log.error('connected to slapd') log.error('connected to slapd')
try: try:
log.info('trying to read last req from {}'.format(log_file_deltalog)) log.error('trying to read last req from {}'.format(log_file_deltalog))
last_line = getlastline(log_file_deltalog).decode('utf-8') last_line = getlastline(log_file_deltalog).decode('utf-8')
#req_json = last_line.split(': ', maxsplit=1)[1] #req_json = last_line.split(': ', maxsplit=1)[1]
req_json = last_line.split(' >>> ', maxsplit=1)[1] req_json = last_line.split(' >>> ', maxsplit=1)[1]
...@@ -233,11 +235,11 @@ def main(): ...@@ -233,11 +235,11 @@ def main():
log.debug('last line pretty:') log.debug('last line pretty:')
log.debug(pprint.pformat(req, indent=1)) log.debug(pprint.pformat(req, indent=1))
req_start = req['attributes']['reqStart'][0] req_start = req['attributes']['reqStart'][0]
log.info('continuing from last logged req: {}'.format(req_start)) log.error('continuing from last logged req: {}'.format(req_start))
except: except:
log.exception('error: trying to retrieve last req') log.exception('error: trying to retrieve last req')
req_start = datetime.datetime.utcnow().strftime('%Y%m%d%H%M%S.%fZ') req_start = datetime.datetime.utcnow().strftime('%Y%m%d%H%M%S.%fZ')
log.info('using current timestamp: {}'.format(req_start)) log.error('using current timestamp: {}'.format(req_start))
while True: while True:
start_time = time.perf_counter() start_time = time.perf_counter()
...@@ -261,7 +263,7 @@ def main(): ...@@ -261,7 +263,7 @@ def main():
req_type = entry['attributes']['reqType'][0] req_type = entry['attributes']['reqType'][0]
req_dn = entry['attributes']['reqDN'][0] req_dn = entry['attributes']['reqDN'][0]
log.info('processing: {}'.format(entry['dn'])) log.debug('processing: {}'.format(entry['dn']))
if req_type == 'modify': if req_type == 'modify':
if is_skipped(entry): if is_skipped(entry):
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment