GetAzureQueueStorage_v12 Processor
描述
从 Azure 队列存储检索消息。 默认情况下，检索到的消息将从队列中删除。 如果要求使用消息而不删除它们，请将“自动删除消息”设置为“false”。 注意：在某些情况下，例如收到消息但由于某些意外情况而无法从队列中删除时，可能会收到重复消息。
标签
属性
| 名称 | 默认值 | 可选值 | 描述 |
|---|---|---|---|
| Queue Name | | Azure 存储队列的名称 支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值） | |
| Endpoint Suffix | queue.core.windows.net | 公共 Azure 中的存储帐户始终使用通用 FQDN 后缀。在某些情况下（如 Azure Stack 或非公共 Azure 区域），使用不同的后缀覆盖此端点后缀。 | |
| Credentials Service | | 控制器服务 API：AzureStorageCredentialsService_v12cn.org.acal.lynxus-lynxus-azure-services-api-nar-2.11.8 | 用于获取 Azure 存储凭据的Controller Service。 |
| Auto Delete Messages | true |
| 指定是否从队列中自动删除收到的消息。 |
| Message Batch Size | 32 | 要从队列中检索的消息数。 | |
| Visibility Timeout | 30 secs | 检索到的消息对其他消费者不可见的持续时间。 | |
| Request Timeout | 10 secs | 对 Azure 队列存储的读取或写入请求的超时时间。默认为 1 秒。 | |
| Proxy Configuration Service | | 控制器服务 API：ProxyConfigurationServicecn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8 | 指定代理配置 Controller Service 来代理网络请求。 对于 SOCKS，不保证处理器一定会使用所选的 SOCKS 版本。 |
关系 (Relationships)
| 名称 | 描述 | 自动终止 |
|---|---|---|
success | 所有成功处理的 FlowFiles 都会路由到此关系 | 否 |
写入的 FlowFile 属性
| 名称 | 描述 |
|---|---|
azure.queue.uri | 配置的 Azure Queue Storage 的绝对 URI |
azure.queue.insertionTime | 消息插入队列存储的时间 |
azure.queue.expirationTime | 消息从队列存储中过期的时间 |
azure.queue.messageId | 检索到的消息的ID |
azure.queue.popReceipt | 检索到的消息的弹出回执 |
状态管理
该组件不存储状态。
受限 (Restricted)
该组件不受限。
输入要求
该组件不允许有传入连接。