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

celery.backends.elasticsearch

Elasticsearch result store backend.

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

Elasticsearch Backend.

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

delete(key)

doc_type = 'backend'

es_max_retries = 3

es_retry_on_timeout = False

es_timeout = 10

get(key)

host = 'localhost'

index = 'celery'

mget(keys)

port = 9200

scheme = 'http'

server

set(key, value)