celery.backends.elasticsearch¶

Elasticsearch result store backend.

class celery.backends.elasticsearch.ElasticsearchBackend(url=None, *args, **kwargs)[исходный код]¶

Elasticsearch Backend.

Исключение:

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

decode(payload)[исходный код]¶

delete(key)[исходный код]¶

doc_type = 'backend'¶

encode(data)[исходный код]¶

es_max_retries = 3¶

es_retry_on_timeout = False¶

es_timeout = 10¶

exception_safe_to_retry(exc)[исходный код]¶

Check if an exception is safe to retry.

Backends have to overload this method with correct predicates dealing with their exceptions.

By default no exception is safe to retry, it’s up to backend implementation to define which exceptions are safe.

get(key)[исходный код]¶

host = 'localhost'¶

index = 'celery'¶

mget(keys)[исходный код]¶

password = None¶

port = 9200¶

scheme = 'http'¶

property server¶

set(key, value)[исходный код]¶

username = None¶