From 95e525db5a7c31d117296ee8d69fc433dfb0f86f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jerem=C3=ADas?= Date: Tue, 16 Mar 2021 13:27:17 -0300 Subject: [PATCH] mongo_lag load env.MONGO_DB_URI --- plugins/mongodb/mongo_lag | 24 ++++++++++++++++-------- 1 file changed, 16 insertions(+), 8 deletions(-) diff --git a/plugins/mongodb/mongo_lag b/plugins/mongodb/mongo_lag index b494e4bc..1229b971 100755 --- a/plugins/mongodb/mongo_lag +++ b/plugins/mongodb/mongo_lag @@ -20,6 +20,11 @@ Default for host is 127.0.0.1 and port 27017 and will work without being defined env.username user env.password P@55w0rd + or + + [mongo_lag] + env.MONGO_DB_URI mongodb://user:passwd@127.0.0.1:27017 + =head1 AUTHOR Stefan Andersen @@ -44,14 +49,17 @@ import sys import pymongo def _get_members(): - host = os.environ.get('host', '127.0.0.1') - port = os.environ.get('port', 27017) - username = os.environ.get('username', '') - password = os.environ.get('password', '') - conn = pymongo.MongoClient(host, int(port)) - if username: - connAuth = conn['admin'] - connAuth.authenticate(username, password) + if 'MONGO_DB_URI' in os.environ: + conn = pymongo.MongoClient(os.environ['MONGO_DB_URI']) + else: + host = os.environ.get('host', '127.0.0.1') + port = os.environ.get('port', 27017) + username = os.environ.get('username', '') + password = os.environ.get('password', '') + conn = pymongo.MongoClient(host, int(port)) + if username: + connAuth = conn['admin'] + connAuth.authenticate(username, password) repl_status = conn.admin.command("replSetGetStatus")