你正在阅读 Celery 3.1 的文档。开发版本文档见: 此处.

celery.backends.rpc

celery.backends.rpc

RPC-style result backend, using reply-to and one queue per client.

class celery.backends.rpc.RPCBackend(app, connection=None, exchange=None, exchange_type=None, persistent=None, serializer=None, auto_delete=True, **kwargs)[源代码]
class Consumer(channel, queues=None, no_ack=None, auto_declare=None, callbacks=None, on_decode_error=None, on_message=None, accept=None)[源代码]
auto_declare = False
RPCBackend.binding None[源代码]
RPCBackend.destination_for(task_id, request)[源代码]
RPCBackend.oid None[源代码]
RPCBackend.on_reply_declare(task_id)[源代码]
RPCBackend.on_task_call(producer, task_id)[源代码]
RPCBackend.persistent = False
RPCBackend.rkey(task_id)[源代码]

上一个主题

celery.backends.base

下一个主题

celery.backends.database

本页