prozorro_sale.tools.wrapers.db.mongo moduleΒΆ
- class prozorro_sale.tools.wrapers.db.mongo.MongoDbWrapper(url, database, write_concern='majority', context_var=None, appname=None)[source]
Bases:
object- DB_INDEXES = {}
- async __aenter__()[source]
Method to get aiohttp.ClientSession.
- async __aexit__(exc_type, exc_val, exc_tb)[source]
Method to close aiohttp.ClientSession.
- __client
- __database
- __init__(url, database, write_concern='majority', context_var=None, appname=None)[source]
- __slots__ = ('__client', '__database', '_appname', '_url', '_database', '_write_concern', '_watch_cursors', '_context_var')
- _appname
- _context_var
- _database
- _url
- _watch_cursors
- _write_concern
- property async_database
- async close()[source]
- async close_cursor(fetch_stream)[source]
- async create_indexes()[source]
- async init()[source]
Initialize DB.
- Returns
None
- property sync_database
- watch_cursor(collection, **kwargs)[source]