This document describes the current stable version of Celery (4.3). For development docs, go here.

celery.backends.elasticsearch

Elasticsearch result store backend.

class celery.backends.elasticsearch.ElasticsearchBackend(url=None, *args, **kwargs)[source]

Elasticsearch Backend.

Raises:celery.exceptions.ImproperlyConfigured – if module elasticsearch is not available.
delete(key)[source]
doc_type = 'backend'
es_max_retries = 3
es_retry_on_timeout = False
es_timeout = 10
get(key)[source]
host = 'localhost'
index = 'celery'
mget(keys)[source]
port = 9200
scheme = 'http'
server
set(key, value)[source]