diff --git a/bin/deltalogparse.py b/bin/deltalogparse.py index 41cd05f8fe7949e4e4f3b0a78ac69ad67752a2cd..d2468b8dff62cb012c0fea0aa3a1f601cb20842c 100755 --- a/bin/deltalogparse.py +++ b/bin/deltalogparse.py @@ -110,7 +110,11 @@ def write(entry): filtered_entry = filtered(entry) log_action('write', filtered_entry) - deltalog.info('{}'.format(json.dumps(filtered_entry))) + + try: + deltalog.info('{}'.format(json.dumps(filtered_entry))) + except: + log.exception('error: writing entry: {} with {}: {}'.format(entry['dn'], req_type, req_dn)) def sleep(start_time): @@ -145,7 +149,7 @@ def main(): req_start = req['attributes']['reqStart'][0] log.info('continuing from last logged req: {}'.format(req_start)) except: - log.exception('error: while 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') log.info('using current timestamp: {}'.format(req_start))