panko.storage.mongo package¶
Submodules¶
panko.storage.mongo.utils module¶
Common functions for MongoDB backend
-
class
panko.storage.mongo.utils.ConnectionPool¶ Bases:
object-
connect(url, max_retries, retry_interval)¶
-
-
class
panko.storage.mongo.utils.CursorProxy(cursor, max_retry, retry_interval)¶ Bases:
pymongo.cursor.Cursor
-
class
panko.storage.mongo.utils.MongoProxy(conn, max_retries, retry_interval)¶ Bases:
object-
create_index(keys, name=None, *args, **kwargs)¶
-
find(*args, **kwargs)¶
-
-
panko.storage.mongo.utils.make_events_query_from_filter(event_filter)¶ Return start and stop row for filtering and a query.
Query is based on the selected parameter.
- Parameters
event_filter – storage.EventFilter object.
-
panko.storage.mongo.utils.make_timestamp_range(start, end, start_timestamp_op=None, end_timestamp_op=None)¶ Create the query document to find timestamps within that range.
This is done by given two possible datetimes and their operations. By default, using $gte for the lower bound and $lt for the upper bound.
