Merge pull request #5672 from Countly/anna/next

Option to do not output error on aggregation pipeline.

Author: Cookiezaurs

bin/upgrade/24.10/scripts/merge_events_collections.js

@@ -46,7 +46,7 @@ async function merge_data_from_collection(countlyDB, collection, mapped, resolve
         var app_id = mapped[collection].a;
         var prefix = app_id + "_" + collection.replace("events", "");
         var tscheck = Date.now().valueOf();
-        countlyDB.collection(collection).aggregate([{"$match": {"merged": {"$ne": true}}}, {"$addFields": {"_id": {"$concat": [prefix, "_", "$_id"]}, "tscheck": tscheck, "a": app_id, "e": mapped[collection].e}}, {"$merge": {"into": "events_data", "on": "_id", "whenMatched": "fail"}}], async function(err) {
+        countlyDB.collection(collection).aggregate([{"$match": {"merged": {"$ne": true}}}, {"$addFields": {"_id": {"$concat": [prefix, "_", "$_id"]}, "tscheck": tscheck, "a": app_id, "e": mapped[collection].e}}, {"$merge": {"into": "events_data", "on": "_id", "whenMatched": "fail"}}], {ignore_errors: [11000]}, async function(err) {
             if (err) {
                 console.log("Failed to merge with database  $merge operation. Doing each document one by one");
 

plugins/pluginManager.js

@@ -2569,10 +2569,12 @@ var pluginManager = function pluginManager() {
                 }
                 return function(err, res) {
                     if (err) {
-                        logDbRead.e("Error reading " + collection + " %j %s %j", data, err, err);
-                        logDbRead.d("From connection %j", countlyDb._cly_debug);
-                        if (e) {
-                            logDbRead.e(e.stack);
+                        if (!(data && data.args && data.args[1] && data.args[1].ignore_errors && data.args[1].ignore_errors.indexOf(err.code) !== -1)) {
+                            logDbRead.e("Error reading " + collection + " %j %s %j", data, err, err);
+                            logDbRead.d("From connection %j", countlyDb._cly_debug);
+                            if (e) {
+                                logDbRead.e(e.stack);
+                            }
                         }
                     }
                     if (callback) {