PublishAMQP 2025.10.2.19¶

捆绑包¶

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。
Header Separator	用于拆分标头的键值的字符。该值只能有一个字符。否则，您将收到一条错误消息
标头模式	该正则表达式将根据 FlowFile 属性进行求值，以选择匹配的属性并将其作为 AMQP 标头。属性名称将用作标头键。
标头源	将应用于已发布消息的标题来源。
主机名	AMQP 代理的网络地址（例如，localhost）。如果设置了代理，则忽略此属性。
密码	用于身份验证与授权的密码。
端口	标识 AMQP 代理端口的数值（例如，5671）。如果设置了代理，则忽略此属性。
路由键	路由键的名称，AMQP 将使用此路由键将消息从交换器路由到目标队列。通常由管理员提供（例如，“myKey”）。如果将消息发送到默认交换器，则此属性对应于目标队列名称，否则，必须设置通过路由键从交换器到队列的绑定（通常由 AMQP 管理员设置）
SSL Context Service	用于为 TLS/SSL 连接提供客户端证书信息的 SSL Context Service。
用户名	用于身份验证和授权的用户名。
虚拟主机	虚拟主机名，用于隔离 AMQP 系统以增强安全性。

关系¶

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