k-space
/
logmower-shipper-prototype
9
0
Fork 0
Code

Elaborate on bulk insertion errors
continuous-integration/drone Build is passing Details

This commit is contained in:
Lauri Võsandi 2022-11-07 08:27:38 +02:00
parent bfe310b9b0
commit 1e82d2af51
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
log_shipper.py
View File

@ -203,7 +203,8 @@ async def uploader(coll, queue):
histogram_database_operation_latency.labels("insert-many").observe(time() - then) histogram_database_operation_latency.labels("insert-many").observe(time() - then)
except pymongo.errors.ServerSelectionTimeoutError: except pymongo.errors.ServerSelectionTimeoutError:
continue continue
except pymongo.errors.BulkWriteError: except pymongo.errors.BulkWriteError as e:
print("Bulk insertion failed:", e)
counter_bulk_insertions.labels("failed").inc() counter_bulk_insertions.labels("failed").inc()
for o in messages: for o in messages:
o.pop("_id", None) o.pop("_id", None)