外部节点
所使用的外部节点用于与外部系统进行交互。
AWS SNS Node
外部节点指用来与外部系统交互的节点 AWS SNS (Amazon Simple Notification Service).
配置:
Topic ARN pattern - 可以为消息发布设置直接主题名，也可以使用模式，使用消息元数据将其解析为真正的主题名.
AWS Access Key ID and AWS Secret Access Key 是具有编程访问权限的AWS IAM用户凭据。更多关于AWS访问密钥的信息，请访问这里找到。
AWS Region 必须对应于创建SNS主题的区域。AWS区域当前列表可以在这里找到。
在下面的例子中，主题名取决于设备类型，在元数据中有一条消息包含deviceType字段
{
deviceType: controller
}我们将在Topic ARN pattern中设置controller的topic中发布消息:
arn:aws:sns:us-east-1:123456789012:${deviceType}在运行时，模式将解析为 arn:aws:sns:us-east-1:123456789012:controller
Published payload - —节点将向SNS发布完整的有效消息负载。如果有需要的话，可以配置规则链，使用转换节点链向SNS发送正确的负载。
Outbound message 将包含消息元数据中的响应messageId和requestId。原始消息有效负载、类型和发送方不会被更改。
AWS SQS Node
节点将消息发布到AWS SQS (亚马逊简单队列服务)。
配置:
Queue Type -SQS队列类型可以是Standard，也可以是先进先出类型FIFO.
Queue URL Pattern - 用于构建队列URL的模式。例如,
${deviceType}。可以为消息发布设置直接队列URL，或使用模式，使用消息元数据将该模式解析为真正的队列URL。Delay - 以秒为单位的延迟，用于延迟特定的消息.
Message attributes - 可选的要发布的消息属性列表.
AWS Access Key ID and AWS Secret Access Key 是具有编程访问权限的AWS IAM用户的凭证。可以在此处找到有关AWS访问密钥的更多信息
AWS Region 必须与创建SQS队列的区域相对应。可在此处找到AWS区域的最新列表。
在以下示例中，队列URL取决于设备类型，并且在元数据中有一个包含 deviceType 字段的消息:
{
deviceType: controller
}为了在 controller’s 的Queue中发布消息，我们将在Queue URL pattern模式中设置此模式:
https://sqs.us-east-1.amazonaws.com/123456789012/${deviceType}在运行时，模式将解析为https://sqs.us-east-1.amazonaws.com/123456789012/controller
Published body - 节点将向SQS发布完整的消息有效负载。如果需要，可以将规则链配置为使用转换节点链，以将正确的有效负载发送到SQS。
Published attributes - 可以添加可选的属性列表以在SQS中发布消息。这是一个集合 – 对。NAME和VALUE都可以是静态值或模式，可以使用消息元数据进行解析。
如果选择了FIFO队列，则消息ID将用作重复数据deduplication ID，消息发起者将用作group ID。
Outbound message 这个节点的出站消息将包含消息元数据中的响应 messageId, requestId, messageBodyMd5, messageAttributesMd5 和 sequenceNumber 原始消息payload、类型和发送方不会被更改。
Kafka Node
Kafka节点向Kafka代理发送消息。消息可具有任何消息类型。将通过Kafka生产者发送记录到Kafka服务器.
配置:
Topic pattern - 可以是静态字符串，也可以是使用消息元数据属性解析的模式。例如
${deviceType}bootstrap servers - 用逗号分隔的kafka代理列表.
Automatically retry times - 如果连接失败，尝试重发消息的次数.
Produces batch size - 以字节为单位的批处理大小，用于对具有相同分区的消息进行分组.
Time to buffer locally - ms中最大的本地缓冲窗口持续时间.
Client buffer max size - 发送消息的最大缓冲区大小(以字节为单位).
Number of acknowledgments - 确认节点在考虑请求完成之前需要接收的数量.
Key serializer - 默认是org.apache.kafka.common.serialization.StringSerializer
Value serializer - 默认是org.apache.kafka.common.serialization.StringSerializer
Other properties - 可以为kafka代理连接提供任何其他属性.
Published body - Node将向Kafka主题发送完整的消息负载。如果需要可以配置规则链，使用转换节点链向Kafka发送正确的payload.
Outbound message 此节点的出站消息将在消息元数据中包含响应offset, partition and topic属性。原始消息payload、类型和发送方不会被更改。
注意-如果您要将Confluent cloud用作kafka代理，则应添加下一个属性：
键
值
ssl.endpoint.identification.algorithm
https
sasl.mechanism
PLAIN
sasl.jaas.config
org.apache.kafka.common.security.plain.PlainLoginModule必需username =“ CLUSTER_API_KEY” password =“ CLUSTER_API_SECRET”;
security.protocol
SASL_SSL
CLUSTER_API_KEY-群集设置中的访问密钥。
CLUSTER_API_SECRET-您在“群集”设置中的访问密码。
MQTT Node
使用QoS AT_LEAST_ONCE将传入消息有效负载发布到已配置的MQTT代理的主题
配置:
Topic pattern - 可以是静态字符串，也可以是使用消息元数据属性解析的模式。例如
${deviceType}.Host - MQTT代理主机.
Port - MQTT代理端口.
Connection timeout - 连接到MQTT代理的超时(秒).
Client ID - 可选的客户端标识符，用于连接到MQTT代理。如果没有指定，将使用默认生成的clientId.
SSL Enable/Disable - 启用/禁用安全通信.
Credentials - MQTT连接凭据。可以是匿名的，基本的或者PEM。
外部MQTT代理支持不同的身份验证凭证:
Anonymous - 没有身份验证
Basic - 用户名\密码对用于认证
PEM - PEM证书用于身份验证
PEM PEM证书用于身份验证 如果选择PEM凭证类型:
CA证书文件
证书文件
私钥文件
私钥密码
Published body - 节点将向MQTT主题发送完整的消息有效负载。如果需要，可以将规则链配置为使用转换节点链，以将正确的有效负载发送到MQTT代理.
在成功发布消息的情况下，原始消息将通过Success链传递到下一个节点，否则将使用Failure链。
Azure IoT Hub Node
配置:
主题-有关IoT中心主题使用链接的更多信息。
主机名-Azure IoT中心主机名。
设备ID-您来自Azure IoT中心的设备ID。
凭据-Azure IoT中心连接凭据。可以是共享访问签名或PEM。
Azure IoT中心支持不同的身份验证凭据：
共享访问签名-SAS密钥用于身份验证
PEM-PEM证书用于身份验证
如果选择了共享访问签名凭据类型，则应提供以下配置：
SAS密钥-它是Azure IoT中心中设备的密钥
CA证书文件，默认情况下使用的是巴尔的摩证书。有关证书的更多信息，请点击此处
如果选择了PEM凭证类型，则应提供以下配置：
CA证书文件，默认情况下使用的是巴尔的摩证书。有关证书的更多信息，请点击此处
证书文件
私钥文件
私钥密码
已发布的正文-节点会将完整的消息有效负载发送到Azure IoT中心设备。如果需要，可以将规则链配置为使用转换节点链，以将正确的有效负载发送到Azure IoT中心。
在成功发布消息的情况下，原始消息将通过成功链传递到下一个节点，否则将使用失败链。
RabbitMQ Node
将传入的消息有效负载发布到RabbitMQ.
配置:
Exchange name pattern - 发布消息时所做的交换。可以是静态字符串，也可以是使用消息元数据属性解析的模式。例如
${deviceType}.Routing key pattern - 路由密钥。可以是静态字符串，也可以是使用消息元数据属性解析的模式。例如
${deviceType}.Message properties - 可选的路由headers。支持TEXT_PLAIN, MINIMAL_BASIC, MINIMAL_PERSISTENT_BASIC, PERSISTENT_BASIC, PERSISTENT_TEXT_PLAIN
Host - 用于连接的默认主机
Port - 用于连接的默认端口
Virtual host - 连接代理时要使用的虚拟主机
Username - AMQP用户名，在连接代理时使用
Password - AMQP连接代理时使用的密码
Automatic recovery - 启用或禁用自动连接恢复
Connection timeout - 连接建立TCP超时，以毫秒为单位;零表示无限
Handshake timeout - AMQP0-9-1协议握手超时，以毫秒为单位
Client properties - 启动连接时发送到服务器的附加属性
Published body - 已发布的主体-节点将向RabbitMQ发送完整的消息有效负载。
如果需要，可以配置规则链，使用转换节点链发送正确的负载。 如果消息发布成功，原始消息将通过Success链传递到下一个节点，否则将使用Failure链。
REST API Call Node
REST API调用外部REST服务器。
配置:
Endpoint URL pattern - 可以是静态字符串，也可以是使用消息元数据属性解决的模式。例如
${deviceType}Request method - GET, POST, PUT, DELETE
Headers - 请求Headers、Headers或值可以是静态字符串，也可以是使用消息元数据属性解析的模式。
Endpoint URL
URL可以是静态字符串或patterns。只使用消息元数据解析模式。因此，模式中使用的属性名必须存在于消息元数据中，否则原始模式将被添加到URL中。
例如，如果消息payload包含带有值container的属性deviceType，则此模式:
http://localhost/api/${deviceType}/update
被解析为
http://localhost/api/container/update
Headers
可以配置标题名称/值的集合。 这些标题将被添加到Rest请求中。 模式应用于配置标头名称和标头值。 例如 ${deviceType}. 仅消息元数据用于解决模式。因此，模式中使用的属性名称必须存在于消息元数据中，否则原始模式将添加到标头中。
Request body -节点将向配置的REST端点发送完整的消息Payload。如果需要，可以将规则链配置为使用转换节点链来发送正确的Payload。
Outbound message 将在消息元数据中包含响应状态，status, statusCode, statusReason和headers。 出站消息有效负载将与响应正文相同。原始邮件类型和原始发件人将不会更改。
如果请求成功，则出站消息将通过Success链传递到下一个节点，否则将使用Failure链
Send Email Node
节点通过已配置的邮件服务器发送传入消息。此节点只适用于在创建时使用Email的消息，请使用Success链将此节点与To Email节点连接。
配置:
Use system SMTP settings - 如果启用，将使用在系统级别配置的默认邮件服务器
Protocol - 邮件服务器传输协议：SMTP 或 SMTPS
SMTP host - 邮件服务器主机
SMTP port - 邮件服务器端口
Timeout ms - 读取超时，以毫秒为单位
Enable TLS - 如果为true，则启用STARTTLS命令的使用（如果服务器支持）
Username - 邮件主机上帐户的用户名（如果有）
Password - 邮件主机上帐户的密码（如果有）
该节点可以与在系统级别配置的默认邮件服务器一起使用。 请找到有关 如何配置默认系统SMTP设置的详细信息
如果此节点需要特定的邮件服务器，请禁用Use system SMTP settings复选框，并手动配置邮件服务器。 该节点可以与在系统级别配置的默认邮件服务器一起使用。有关如何配置默认系统SMTP设置请找到的更多详细信息。 如果此节点需要特定的邮件服务器，请禁用使用系统SMTP设置复选框并手动配置邮件服务器
另外，如果传入消息已参考数据库中存储的文件准备了附件字段，则此节点可以创建电子邮件附件。
如果成功发送邮件，原始消息将通过Success链传递到下一个节点，否则将使用Failure链。
最后更新于
这有帮助吗？