From 1e82d2af513343c2ab49639c7f136919b1032498 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Lauri=20V=C3=B5sandi?= Date: Mon, 7 Nov 2022 08:27:38 +0200 Subject: [PATCH] Elaborate on bulk insertion errors --- log_shipper.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/log_shipper.py b/log_shipper.py index 699d9a1..83ee9c5 100755 --- a/log_shipper.py +++ b/log_shipper.py @@ -203,7 +203,8 @@ async def uploader(coll, queue): histogram_database_operation_latency.labels("insert-many").observe(time() - then) except pymongo.errors.ServerSelectionTimeoutError: continue - except pymongo.errors.BulkWriteError: + except pymongo.errors.BulkWriteError as e: + print("Bulk insertion failed:", e) counter_bulk_insertions.labels("failed").inc() for o in messages: o.pop("_id", None)