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)

Send task return value and status.

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

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

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