Skip to content

Script Development / MongoDB

The MongoDB connector operation object primarily provides some methods for operating on MongoDB.

DFF.CONN(...) parameters are as follows:

Parameter Type Required / Default Value Description
connector_id str Required Connector ID
database str None Specify database

.db(...)

Get the database operation object, parameters are as follows:

Parameter Type Required / Default Value Description
db_name str None Database name. When no name is passed, returns the default database operation object.
Example
 1
 2
 3
 4
 5
 6
 7
 8
 9
10
# Get the default database object
db = helper.db()
# Get the specified database object
db = helper.db('some_db')
# Get the collection object
collection = db['some_collection']
# Query processing
data = collection.find_one()
# Written in one line
data = helper.db('some_db')['some_collection'].find_one()

.run_method(...)

The run_method() method is used to get the list of databases or collections, parameters are as follows:

Parameter Type Required / Default Value Description
method str Required Execution method, enumeration:
list_database_names: List databases
list_collection_names: List collections
db_name str None Can be passed when executing list_collection_names, specify database;
Not passing it defaults to the default database
Must be passed as a named parameter
Example
1
2
3
db_list = helper.run_method('list_database_names')
collection_list = helper.run_method('list_collection_names')
collection_list = helper.run_method('list_collection_names', db_name='some_db')

For specific query syntax, format, etc., please refer to the official MongoDB documentation.