你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn

AmqpMessageHeader 类

消息标头。 消息标头。 这仅适用于收到的消息,不对正在发送的消息进行设置。 针对任何给定消息设置的属性将取决于服务,并非所有消息都具有所有属性。 有关消息标头的详细信息,请参阅 AMQP 规范: http://docs.oasis-open.org/amqp/core/v1.0/os/amqp-core-messaging-v1.0-os.html#type-header

继承
azure.servicebus.amqp._amqp_message.DictMixin
AmqpMessageHeader

构造函数

AmqpMessageHeader(*, delivery_count: int | None = None, time_to_live: int | None = None, durable: bool | None = None, first_acquirer: bool | None = None, priority: int | None = None, **kwargs: Any)

仅限关键字的参数

名称 说明
delivery_count

以前传递此消息的失败尝试次数。 如果此值为非零,则可以将其视为传递可能重复的指示。 首次送达时,该值为零。 根据为每个结果定义的规则,在发送方结算结果时,它会递增。

time_to_live

消息被视为“实时”的持续时间(以毫秒为单位)。 如果设置了此设置,则会根据中间的到达时间计算消息过期时间。 生存期超过其过期时间的邮件将被丢弃 (或死信) 。 当消息由使用 ttl 接收的中介传输时,传输的消息头应包含一个 ttl,该 ttl 作为当前时间和以前计算的消息过期时间(即减少的 ttl)之间的差计算,因此,如果消息最终在传递循环中,则消息最终会死亡。

durable

即使中介意外终止并重新启动,持久消息也不得丢失。 无法满足此保证的目标不得接受持久标头设置为 True 的消息:如果源允许拒绝的结果,则消息应被拒绝并出现前提条件失败错误,否则接收方必须分离链接并出现相同错误。

first_acquirer

如果此值为 True,则表示任何其他链接尚未获取此消息。 如果此值为 False,则表示此消息可能以前已由另一个或多个链接获取。

priority

此字段包含相对消息优先级。 数字越大,表示优先级越高的消息。 优先级较高的消息可以先于优先级较低的邮件传递。

变量

名称 说明
delivery_count

以前传递此消息的失败尝试次数。 如果此值为非零,则可以将其视为传递可能重复的指示。 首次送达时,该值为零。 根据为每个结果定义的规则,在发送方结算结果时,它会递增。

time_to_live

消息被视为“实时”的持续时间(以毫秒为单位)。 如果设置了此设置,则会根据中间的到达时间计算消息过期时间。 生存期超过其过期时间的邮件将被丢弃 (或死信) 。 当消息由使用 ttl 接收的中介传输时,传输的消息头应包含一个 ttl,该 ttl 作为当前时间和以前计算的消息过期时间(即减少的 ttl)之间的差计算,因此,如果消息最终在传递循环中,则消息最终会死亡。

durable

即使中介意外终止并重新启动,持久消息也不得丢失。 无法满足此保证的目标不得接受持久标头设置为 True 的消息:如果源允许拒绝的结果,则消息应被拒绝并出现前提条件失败错误,否则接收方必须分离链接并出现相同错误。

first_acquirer

如果此值为 True,则表示任何其他链接尚未获取此消息。 如果此值为 False,则表示此消息可能以前已由另一个或多个链接获取。

priority

此字段包含相对消息优先级。 数字越大,表示优先级越高的消息。 优先级较高的消息可以先于优先级较低的邮件传递。

方法

get
has_key
items
keys
update
values

get

get(key: str, default: Any | None = None) -> Any

参数

名称 说明
key
必需
default
默认值: None

has_key

has_key(k: str) -> bool

参数

名称 说明
k
必需

items

items() -> List[Tuple[str, Any]]

keys

keys() -> List[str]

update

update(*args: Any, **kwargs: Any) -> None

values

values() -> List[Any]