This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 5.0.

烟火运输- kombu.transport.pyro

Kombu的烟火运输舱。

和Kombu Broker守护程序。

需要 Pyro4 要安装的库。

功能

  • 类型：虚拟

  • 支持Direct：是

  • 支持主题：是

  • 支持扇出：否

  • 支持优先级：否

  • 支持TTL：否

连接字符串

要将Pyro传输与Kombu一起使用，请使用以下形式的URL：

pyro://localhost/kombu.broker

主机名是传输将在其中查找Pyro名称服务器的位置，而该名称服务器又用于定位kombu.broker Pyro服务。只需使用以下命令直接执行此传输模块即可启动此代理： python -m kombu.transport.pyro

交通选择

运输

class kombu.transport.pyro.Transport(client, **kwargs)[源代码]

烟火运输公司。

class Channel(connection, **kwargs)

烟火频道。

after_reply_message_received(queue)

在收到RPC回复后调用了回调。

备注

回复队列语义：用于在收到临时回复消息后删除队列。

close()

关闭通道。

取消所有使用者，并重新排队未确认的消息。

queues()
property shared_queues
default_port = 9090

未指定端口时使用的端口号。

driver_name = 'pyro'

驱动程序库的名称(例如‘py-amqp’、‘redis’)。

driver_type = 'pyro'

驱动程序的类型，可用于使用AMQP协议(DRIVER_TYPE：‘AMQP’)、Redis(DRIVER_TYPE：‘REDIS’)等来分隔传输...

driver_version()[源代码]
global_state = <kombu.transport.virtual.base.BrokerState object>
property shared_queues

渠道

class kombu.transport.pyro.Channel(connection, **kwargs)[源代码]

烟火频道。

after_reply_message_received(queue)[源代码]

在收到RPC回复后调用了回调。

备注

回复队列语义：用于在收到临时回复消息后删除队列。

close()[源代码]

关闭通道。

取消所有使用者，并重新排队未确认的消息。

queues()[源代码]
property shared_queues

KombuBroker