celery.backends.mongodb

MongoDB result store backend.

class celery.backends.mongodb.MongoBackend(app=None, **kwargs)[исходный код]

MongoDB result backend.

Исключение:

celery.exceptions.ImproperlyConfigured – if module pymongo is not available.

as_uri(include_password=False)[исходный код]

Return the backend as an URI.

Параметры:

include_password (bool) – Password censored if disabled.

cleanup()[исходный код]

Delete expired meta-data.

property collection

Get the meta-data task collection.

property database

Get database from MongoDB connection.

performs authentication if necessary.

database_name = 'celery'
decode(data)[исходный код]
encode(data)[исходный код]
property expires_delta
property group_collection

Get the meta-data task collection.

groupmeta_collection = 'celery_groupmeta'
host = 'localhost'
max_pool_size = 10
mongo_host = None
options = None
password = None
port = 27017
supports_autoexpire = False

If true the backend must automatically expire results. The daily backend_cleanup periodic task won’t be triggered in this case.

taskmeta_collection = 'celery_taskmeta'
user = None
Back to Top