PublishAMQP 2025.5.31.15¶

捆绑包¶

org.apache.nifi | nifi-amqp-nar

描述¶

根据 FlowFile 的内容创建 AMQP 消息，并将该消息发送到 AMQP 交换器。在典型的 AMQP Exchange 模型中，发送到 AMQP Exchange 的消息将根据“路由键”路由到其队列中的最终目标（绑定）。如果由于某些配置错误而未设置交换器、路由键和队列之间的绑定，则消息将没有最终目标并将返回（即，数据将无法进入队列）。如果发生这种情况，您将在应用程序日志和公告中看到一条注明该内容的日志，并将 FlowFile 路由到“failure”关系。

标签¶

amqp、message、publish、put、rabbit、send

输入要求¶

REQUIRED

支持敏感的动态属性¶

false

属性¶

属性	描述
AMQP 版本	AMQP 版本。目前仅支持 AMQP v0.9.1。
代理	以逗号分隔的已知 AMQP 代理列表，格式为 <host>:<port>（例如，localhost:5672）。如果设置了此属性，则忽略“Host Name”和“Port”。仅包括来自同一 AMQP 集群的主机。
已启用客户端证书身份验证	使用 SSL 证书而非用户名/密码进行身份验证。
Exchange 名称	消息将发送到的 AMQP Exchange 的名称。通常由 AMQP 管理员提供（例如，“amq.direct”）。这是一个可选属性。如果保留为空，则消息将发送到默认 AMQP Exchange。
标头模式	该正则表达式将根据 FlowFile 属性进行求值，以选择匹配的属性并将其作为 AMQP 标头。属性名称将用作标头键。
标头源	将应用于已发布消息的标题来源。
主机名	AMQP 代理的网络地址（例如，localhost）。如果设置了代理，则忽略此属性。
密码	用于身份验证与授权的密码。
端口	标识 AMQP 代理端口的数值（例如，5671）。如果设置了代理，则忽略此属性。
路由键	路由键的名称，AMQP 将使用此路由键将消息从交换器路由到目标队列。通常由管理员提供（例如，“myKey”）。如果将消息发送到默认交换器，则此属性对应于目标队列名称，否则，必须设置通过路由键从交换器到队列的绑定（通常由 AMQP 管理员设置）
SSL Context Service	用于为 TLS/SSL 连接提供客户端证书信息的 SSL Context Service。
用户名	用于身份验证和授权的用户名。
虚拟主机	虚拟主机名，用于隔离 AMQP 系统以增强安全性。
header.separator	用于拆分标头的键值的字符。该值只能有一个字符。否则，您将收到一条错误消息

关系¶

名称	描述
failure	所有无法路由到 AMQP 目标的 FlowFiles 都会路由到此关系
success	发送到 AMQP 目标的所有 FlowFiles 都会路由到此关系