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

celery.backends.riak

Riak result store backend.

class celery.backends.riak.RiakBackend(host=None, port=None, bucket_name=None, protocol=None, url=None, *args, **kwargs)[source]

Riak result backend.

Raises:celery.exceptions.ImproperlyConfigured – if module riak is not available.
bucket
bucket_name = 'celery'

default Riak bucket name (default)

client
delete(key)[source]
get(key)[source]
host = 'localhost'

default Riak server hostname (localhost)

mget(keys)[source]
port = 8087

default Riak server port (8087)

protocol = 'pbc'

default protocol used to connect to Riak, might be http or pbc

set(key, value)[source]