From d8fbc0ed24f2d2e2160672d498cf207fec525858 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Sven=20M=C3=A4der?= <maeder@phys.ethz.ch>
Date: Wed, 11 Apr 2018 15:16:11 +0200
Subject: [PATCH] Add output exception handling
---
bin/deltalogparse.py | 8 ++++++--
1 file changed, 6 insertions(+), 2 deletions(-)
diff --git a/bin/deltalogparse.py b/bin/deltalogparse.py
index 41cd05f..d2468b8 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))
--
GitLab