GetSQS Processor
描述
从 Amazon Simple Queuing Service 队列中获取消息
标签
属性
| 名称 | 默认值 | 可选值 | 描述 |
|---|---|---|---|
| Queue URL | | 从中获取消息的队列的 URL 支持表达式语言:是(仅使用环境/系统变量求值) | |
| Region | us-west-2 |
| 服务所在的 AWS 区域 |
| Custom Region | | 自定义区域,例如 AWS 兼容服务提供商的区域 支持表达式语言:是(仅使用环境/系统变量求值) | |
| AWS Credentials Provider Service | | 控制器服务 API:AwsCredentialsProviderServicecn.org.acal.lynxus-lynxus-aws-service-api-nar-2.11.8 | 用于获取AWS凭证提供者的Controller Service |
| SSL Context Service | | 控制器服务 API:SSLContextProvidercn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8 | 指定可选的 SSL 上下文服务,如果提供,将用于创建连接 |
| Auto Delete Messages | true |
| 指定处理器收到消息后是否应自动删除消息。 |
| Batch Size | 10 | 单个网络请求中发送的最大消息数 | |
| Communications Timeout | 30 secs | ||
| Endpoint Override URL | | 用于替代 AWS 默认端点的端点 URL,包括协议、主机、端口和路径。AWS 库根据 AWS 区域选择端点 URL,但此属性会覆盖所选端点 URL,允许与其他 S3 兼容端点一起使用。 支持表达式语言:是(仅使用环境/系统变量求值) | |
| Character Set | UTF-8 |
| 用于编码 SQS 消息文本内容的字符集 |
| Visibility Timeout | 15 mins | 收到消息但未删除该消息后,该消息对其他消费者隐藏的时间量 | |
| Receive Message Wait Time | 0 sec | 长轮询接收调用等待的最长时间。将此值设置为 1 秒或更大将减少 SQS 请求数量并降低获取延迟,但代价是线程持续活跃。 | |
| Proxy Configuration Service | | 控制器服务 API:ProxyConfigurationServicecn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8 | 指定代理配置 Controller Service 来代理网络请求。 |
关系 (Relationships)
| 名称 | 描述 | 自动终止 |
|---|---|---|
success | FlowFiles被路由到成功关系 | 否 |
写入的 FlowFile 属性
| 名称 | 描述 |
|---|---|
hash.value | 消息的 MD5 校验和 |
hash.algorithm | MD5 |
sqs.message.id | SQS 消息的唯一标识符 |
sqs.receipt.handle | 用于从队列中删除消息的 SQS 收据句柄 |
状态管理
该组件不存储状态。
受限 (Restricted)
该组件不受限。
输入要求
该组件不允许有传入连接。