celery.backends.cosmosdbsql

The CosmosDB/SQL backend for Celery (experimental).

class celery.backends.cosmosdbsql.CosmosDBSQLBackend(url=None, database_name=None, collection_name=None, consistency_level=None, max_retry_attempts=None, max_retry_wait_time=None, *args, **kwargs)[源代码]

CosmosDB/SQL backend for Celery.

delete(key)[源代码]

Delete the value at a given key.

参数:

key -- The key of the value to delete.

get(key)[源代码]

Read the value stored at the given key.

参数:

key -- The key for which to read the value.

mget(keys)[源代码]

Read all the values for the provided keys.

参数:

keys -- The list of keys to read.

set(key, value)[源代码]

Store a value for a given key.

参数:
  • key -- The key at which to store the value.

  • value -- The value to store.