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

ETCD运输- kombu.transport.etcd

用于Kombu的ETCD传输模块。

它使用etcd作为存储来传输队列中的消息

它使用python-etcd与etcd的HTTP API对话

功能

  • 类型：虚拟

  • 支持Direct： Unreviewed

  • 支持主题： Unreviewed

  • 支持扇出： Unreviewed

  • 支持优先级： Unreviewed

  • 支持TTL： Unreviewed

连接字符串

连接字符串的格式如下：

'etcd'://SERVER:PORT

运输

class kombu.transport.etcd.Transport(*args, **kwargs)[源代码]

Kombu的ETCD存储运输。

class Channel(*args, **kwargs)

与etcd对话的Channel类。

index = None
lock_ttl = 10
property lock_value
prefix = 'kombu'
session_ttl = 30
timeout = 10
default_port = 2379

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

driver_name = 'python-etcd'

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

driver_type = 'etcd'

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

driver_version()[源代码]

返回etcd库的版本。

备注

Python-etcd没有 __version__. 这是一种解决方法。

implements = {'asynchronous': False, 'exchange_type': frozenset({'direct'}), 'heartbeats': False}
polling_interval = 3

在不成功的民意调查之间睡觉的时间到了。

verify_connection(connection)[源代码]

验证连接是否工作正常。

渠道

class kombu.transport.etcd.Channel(*args, **kwargs)[源代码]

与etcd对话的Channel类。

index = None
lock_ttl = 10
property lock_value
prefix = 'kombu'
session_ttl = 30
timeout = 10