GetSQS 2025.5.31.15¶
捆绑包¶
org.apache.nifi | nifi-aws-nar
描述¶
从 Amazon Simple Queuing Service Queue 中提取消息
输入要求¶
FORBIDDEN
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
AWS 凭据提供商服务 |
用于获取 AWS 凭证提供商的控制器服务 |
自动删除消息 |
指定处理器在收到消息后是否应自动删除消息。 |
批大小 |
单次网络请求中要发送的最大消息数量。 |
字符集 |
用于对 SQS 消息的文本内容进行编码的 Character Set |
通信超时 |
|
端点替换 URL |
要使用的端点 URL 而不是 AWS 默认端点，包括架构、主机、端口和路径。AWS 库会根据 AWS 区域选择端点 URL，但此属性会替换所选端点 URL，允许与其他与 S3 兼容的端点一起使用。 |
队列 URL |
要接收消息的队列 URL |
接收消息等待时间 |
长轮询接收调用的最大等待时间。设置为 1 秒或更长有助于减少 SQS 请求次数并降低提取延迟，但会保持线程持续活动。 |
区域 |
|
SSL Context Service |
指定可选的 SSL Context Service，如果提供该服务，将用于创建连接 |
可见性超时 |
消息被接收但未被删除后，在其他使用者中被隐藏的时间 |
proxy-configuration-service |
指定代理配置控制器服务来代理网络请求。 |
关系¶
名称 |
描述 |
|---|---|
success |
FlowFiles 将路由到 success 关系 |
写入属性¶
名称 |
描述 |
|---|---|
hash.value |
消息的 MD5 总和 |
hash.algorithm |
MD5 |
sqs.message.id |
SQS 消息的唯一标识符 |
sqs.receipt.handle |
用于从队列中删除消息的 SQS 接收句柄 |