From b471c49cbf415e8e4a25f33536e6bec397f8254a Mon Sep 17 00:00:00 2001 From: Alex Holliday Date: Fri, 16 May 2025 14:08:45 -0700 Subject: [PATCH] unordered bulk insert --- server/db/mongo/modules/checkModule.js | 2 +- server/db/mongo/modules/distributedCheckModule.js | 3 +-- server/db/mongo/modules/hardwareCheckModule.js | 2 +- server/db/mongo/modules/pageSpeedCheckModule.js | 2 +- 4 files changed, 4 insertions(+), 5 deletions(-) diff --git a/server/db/mongo/modules/checkModule.js b/server/db/mongo/modules/checkModule.js index 2b0eb33ba..2339edbed 100755 --- a/server/db/mongo/modules/checkModule.js +++ b/server/db/mongo/modules/checkModule.js @@ -43,7 +43,7 @@ const createCheck = async (checkData) => { const createChecks = async (checks) => { try { - await Check.insertMany(checks); + await Check.insertMany(checks, { ordered: false }); } catch (error) { error.service = SERVICE_NAME; error.method = "createCheck"; diff --git a/server/db/mongo/modules/distributedCheckModule.js b/server/db/mongo/modules/distributedCheckModule.js index 10fc577b2..7200cba33 100755 --- a/server/db/mongo/modules/distributedCheckModule.js +++ b/server/db/mongo/modules/distributedCheckModule.js @@ -128,9 +128,8 @@ const createDistributedChecks = async (checksData) => { }; }); - // Execute bulk operation await DistributedUptimeCheck.bulkWrite(bulkOps, { - ordered: false, // Allow parallel processing + ordered: false, }); } catch (error) { error.service = SERVICE_NAME; diff --git a/server/db/mongo/modules/hardwareCheckModule.js b/server/db/mongo/modules/hardwareCheckModule.js index 738412c60..868c83958 100755 --- a/server/db/mongo/modules/hardwareCheckModule.js +++ b/server/db/mongo/modules/hardwareCheckModule.js @@ -51,7 +51,7 @@ const createHardwareCheck = async (hardwareCheckData) => { const createHardwareChecks = async (hardwareChecks) => { try { - await HardwareCheck.insertMany(hardwareChecks); + await HardwareCheck.insertMany(hardwareChecks, { ordered: false }); return true; } catch (error) { error.service = SERVICE_NAME; diff --git a/server/db/mongo/modules/pageSpeedCheckModule.js b/server/db/mongo/modules/pageSpeedCheckModule.js index f634fae27..9169a0836 100755 --- a/server/db/mongo/modules/pageSpeedCheckModule.js +++ b/server/db/mongo/modules/pageSpeedCheckModule.js @@ -26,7 +26,7 @@ const createPageSpeedCheck = async (pageSpeedCheckData) => { }; const createPageSpeedChecks = async (pageSpeedChecks) => { try { - await PageSpeedCheck.insertMany(pageSpeedChecks); + await PageSpeedCheck.insertMany(pageSpeedChecks, { ordered: false }); return true; } catch (error) { error.service = SERVICE_NAME;