diff --git a/plugins/mongodb/mongo_lag b/plugins/mongodb/mongo_lag
index b70837fc..a54c0f50 100755
--- a/plugins/mongodb/mongo_lag
+++ b/plugins/mongodb/mongo_lag
@@ -25,7 +25,7 @@ import pymongo
 def _get_members():
     host = os.environ.get('host', '127.0.0.1')
     port = os.environ.get('port', 27017)
-    conn = pymongo.Connection(host,port)
+    conn = pymongo.MongoClient(host,port)
     repl_status = conn.admin.command("replSetGetStatus")
 
     members = {}