This document describes an older version of Celery (2.1). For the latest stable version please go here.

Backend: AMQP - celery.backends.amqp

celery.backends.amqp

class celery.backends.amqp.AMQPBackend(connection=None, exchange=None, exchange_type=None, persistent=None, serializer=None, auto_delete=None, expires=None, **kwargs)

AMQP backend. Publish results by sending messages to the broker using the task id as routing key.

NOTE: Results published using this backend is read-once only. After the result has been read, the result is deleted. (however, it’s still cached locally by the backend instance).

close()

connection

consume(task_id, timeout=None)

get_task_meta(task_id, cache=True)

poll(task_id)

reload_task_result(task_id)

reload_taskset_result(task_id)

Reload taskset result, even if it has been previously fetched.

restore_taskset(taskset_id, cache=True)

Get the result of a taskset.

save_taskset(taskset_id, result)

Store the result and status of a task.

store_result(task_id, result, status, traceback=None, max_retries=20, retry_delay=0.2)

Send task return value and status.

wait_for(task_id, timeout=None, cache=True)

exception celery.backends.amqp.AMQResultWarning

class celery.backends.amqp.ResultConsumer(connection, task_id, **kwargs)

auto_delete = True

durable = False

exchange = 'celeryresults'

exchange_type = 'direct'

no_ack = True

class celery.backends.amqp.ResultPublisher(connection, task_id, **kwargs)

auto_delete = True

delivery_mode = 1

durable = False

exchange = 'celeryresults'

exchange_type = 'direct'

serializer = 'pickle'