commit 13ac7a40f8efd8f7135ad06260663ff7e1f63d24
author Vijay Nag B S <vijaynag.bs@tataelxsi.co.in> Tue Sep 29 17:23:57 2020 +0530
committer garciadeblas <gerardo.garciadeblas@telefonica.com> Mon Mar 29 15:33:38 2021 +0200
tree 2bac8166533fc34a84408c45618437390e549e0e
parent 60aa4e61def0e1f1c1470a095092cabb86fa1a2a

Support for mongodb replicaset connection (HA).

Change-Id: I36d582f177d36b93b9913dd781c50ac34b2bbb60
Signed-off-by: Vijay Nag B S <vijaynag.bs@tataelxsi.co.in>
Signed-off-by: garciadeblas <gerardo.garciadeblas@telefonica.com>

osm_common/dbmongo.py

diff --git a/osm_common/dbmongo.py b/osm_common/dbmongo.py
index 3de900b..16ab881 100644
--- a/osm_common/dbmongo.py
+++ b/osm_common/dbmongo.py
@@ -99,9 +99,9 @@
                 self.database_key = master_key
                 self.set_secret_key(master_key)
             if config.get("uri"):
-                self.client = MongoClient(config["uri"])
+                self.client = MongoClient(config["uri"], replicaSet=config.get("replicaset", None))
             else:
-                self.client = MongoClient(config["host"], config["port"])
+                self.client = MongoClient(config["host"], config["port"], replicaSet=config.get("replicaset", None))
             # TODO add as parameters also username=config.get("user"), password=config.get("password"))
             # when all modules are ready
             self.db = self.client[config["name"]]