The panko.storage.impl_mongodb
Module¶
MongoDB storage backend
-
class
panko.storage.impl_mongodb.
Connection
(url, conf)¶ Bases:
panko.storage.pymongo_base.Connection
Put the event data into a MongoDB database.
-
CONNECTION_POOL
= <panko.storage.mongo.utils.ConnectionPool object>¶
-
clear
()¶ Clear database.
-
clear_expired_data
(ttl, max_count=None)¶ Clear expired data from the backend storage system.
Clearing occurs according to the time-to-live.
- Parameters
ttl – Number of seconds to keep records for.
max_count – Number of records to delete (not used for MongoDB).
-
static
update_ttl
(ttl, ttl_index_name, index_field, coll)¶ Update or create time_to_live indexes.
- Parameters
ttl – time to live in seconds.
ttl_index_name – name of the index we want to update or create.
index_field – field with the index that we need to update.
coll – collection which indexes need to be updated.
-
upgrade
()¶ Migrate the database to version or the most recent version.
-