This document describes the current stable version of Celery (4.0). 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 = u'backend'
get(key)[source]
host = u'localhost'
index = u'celery'
mget(keys)[source]
port = 9200
scheme = u'http'
server
set(key, value)[source]