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)