How to run MongoDB commands with pymongo?

Question

I need to see list of connections to MongodDB. I know how to do it in mongo console:

> db.currentOp(true)

Now I want to do the same using pymongo. I tried following and it didn't work:

from pymongo import MongoClient
client = MongoClient(host="myhost.com")
db = client.mydb

After that I used db.command() in various combinations trying to pass "db.currentOp(true)" to it without success.

How to do it properly? The question is how to run a command using pymongo if I know how to run it from db console? Is there a common approach?

disflux · Accepted Answer · 2016-01-14 16:53:29Z

4

A quick glance over the API lead me to what I think you are looking for.

When I worked with PyMongo in the past, something I noticed is that the camelcase functions in the mongo shell (such as db.currentOp()), are converted directly to the python syntax, so it becomes db.current_op().

Try this:

from pymongo import MongoClient
client = MongoClient(host="myhost.com")
db = client.mydb
current_ops = db.current_op(True)

answered Jan 14, 2016 at 16:53

disflux

4393 silver badges12 bronze badges

Sign up to request clarification or add additional context in comments.

Comments

Sede · Accepted Answer · 2016-01-14 17:22:09Z

Every method in the Python driver follows PEP 0008 unless I am strongly mistaken

In Pymongo you need to use the .current_op() method to get information on operations currently running.

from pymongo import MongoClient
client = MongoClient(host="myhost.com")
db = client.mydb
infos = db.current_op()

Of course if you want to list currently idle operations in the result set the positional or keyword argument include_all to True

infos = db.current_op(True) # or infos = db.current_op(include_all=True)

Demo:

In [8]: db.current_op()
Out[8]: 
{'inprog': [{'active': True,
   'client': '127.0.0.1:54268',
   'connectionId': 2,
   'desc': 'conn2',
   'lockStats': {},
   'locks': {},
   'microsecs_running': 45,
   'ns': 'admin.$cmd',
   'numYields': 0,
   'op': 'command',
   'opid': 793,
   'query': {'$all': False, 'currentOp': 1},
   'secs_running': 0,
   'threadId': '140272266217216',
   'waitingForLock': False}],
 'ok': 1.0}

To issue a MongoDB command, the driver provides the .command() method

Teakwood J Overclutch · Accepted Answer · 2022-07-29 17:05:31Z

1

Just for reference, this no longer works in current versions of PyMongo (4.0 or more recent).

The following example is from the documentation:

# Lists all operations currently running on the server.
with client.admin.aggregate([{"$currentOp": {}}]) as cursor:
    for operation in cursor:
        print(operation)

See https://pymongo.readthedocs.io/en/stable/api/pymongo/database.html#module-pymongo.database

As to why it was changed from the more straightforward method call is left as an exercise for the student.

answered Jul 29, 2022 at 17:05

Teakwood J Overclutch

3113 silver badges10 bronze badges

Collectives™ on Stack Overflow

How to run MongoDB commands with pymongo?

3 Answers 3

Comments

Comments

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

3 Answers 3

Comments

Comments

Comments

Your Answer

Sign up or log in

Post as a guest

Related