weaver.database.mongodb

Module Contents

weaver.database.mongodb.LOGGER[source]
weaver.database.mongodb.MongoDB: pymongo.database.Database | None[source]
weaver.database.mongodb.MongodbStores[source]
weaver.database.mongodb.AnyMongodbStore[source]
class weaver.database.mongodb.MongoDatabase(container: weaver.typedefs.AnySettingsContainer)[source]

Return the unique identifier of db type matching settings.

_revision = 1[source]
_database[source]
_settings[source]
_stores[source]
type = 'mongodb'[source]
reset_store(store_type: weaver.database.base.StoreSelector) AnyMongodbStore[source]
get_store(store_type: weaver.database.base.StoreBillsSelector, *store_args: Any, **store_kwargs: Any) weaver.store.mongodb.MongodbBillStore[source]
get_store(store_type: weaver.database.base.StoreQuotesSelector, *store_args: Any, **store_kwargs: Any) weaver.store.mongodb.MongodbQuoteStore
get_store(store_type: weaver.database.base.StoreJobsSelector, *store_args: Any, **store_kwargs: Any) weaver.store.mongodb.MongodbJobStore
get_store(store_type: weaver.database.base.StoreProcessesSelector, *store_args: Any, **store_kwargs: Any) weaver.store.mongodb.MongodbProcessStore
get_store(store_type: weaver.database.base.StoreServicesSelector, *store_args: Any, **store_kwargs: Any) weaver.store.mongodb.MongodbServiceStore
get_store(store_type: weaver.database.base.StoreVaultSelector, *store_args: Any, **store_kwargs: Any) weaver.store.mongodb.MongodbVaultStore

Retrieve a store from the database.

Parameters:
  • store_type – type of the store to retrieve/create.

  • store_args – additional arguments to pass down to the store.

  • store_kwargs – additional keyword arguments to pass down to the store.

get_session() Any[source]
get_information() weaver.typedefs.JSON[source]

Obtain information about the database implementation.

Returns:

JSON with parameters: {"version": "<version>", "type": "<db_type>"}.

is_ready() bool[source]
run_migration() None[source]

Runs any necessary data-schema migration steps.

class weaver.database.mongodb.DecimalCodec[source]

Converter that will automatically perform necessary encoding/decoding of decimal types for MongoDB.

python_type[source]
bson_type[source]
transform_python(value: decimal.Decimal) bson.Decimal128[source]

Convert the given Python object into something serializable.

transform_bson(value: bson.Decimal128) decimal.Decimal[source]

Convert the given BSON value into our own type.

weaver.database.mongodb.get_mongodb_connection(container: weaver.typedefs.AnySettingsContainer) pymongo.database.Database[source]

Obtains the basic database connection from settings.

weaver.database.mongodb.get_mongodb_engine(container: weaver.typedefs.AnySettingsContainer) pymongo.database.Database[source]

Obtains the database with configuration ready for usage.