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.consul

昆布领事运输舱。

功能

它使用Consul.io的键/值存储在队列中传输消息

它使用python-consul与Consul的HTTP API进行对话

功能

  • 类型：原生

  • 支持Direct：是

  • 支持主题： Unreviewed

  • 支持扇出： Unreviewed

  • 支持优先级： Unreviewed

  • 支持TTL： Unreviewed

连接字符串

连接字符串的格式如下：

consul://CONSUL_ADDRESS[:PORT]

运输

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

Kombu领事K/V存储运输。

class Channel(*args, **kwargs)

Consul Channel类，它与Consul Key/Value存储对话。

index = None
property lock_name
prefix = 'kombu'
session_ttl = 30
timeout = '10s'
default_port = 8500

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

driver_name = 'consul'

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

driver_type = 'consul'

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

driver_version()[源代码]
verify_connection(connection)[源代码]

渠道

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

Consul Channel类，它与Consul Key/Value存储对话。

index = None
property lock_name
prefix = 'kombu'
session_ttl = 30
timeout = '10s'