The panko.storage.impl_mongodb Module¶

MongoDB storage backend

service None

Bases: panko.storage.pymongo_base.Connection

Put the event data into a MongoDB database.

Connection.clear()[source]¶

Clear database.

Connection.clear_expired_data(ttl)[source]¶

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.

static Connection.update_ttl(ttl, ttl_index_name, index_field, coll)[source]¶

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.

Connection.upgrade()[source]¶

Migrate the database to version or the most recent version.