GetAzureQueueStorage_v12 2025.5.31.15¶
捆绑包¶
org.apache.nifi | nifi-azure-nar
描述¶
从 Azure Queue Storage 中检索消息。默认情况下，检索到的消息将从队列中删除。如果要求在不删除消息的情况下使用消息，请将“自动删除消息”设置为“false”。注意：在某些异常情况下（例如消息已接收但未能从队列中删除时），可能会出现重复接收消息的情况。
输入要求¶
FORBIDDEN
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
自动删除消息 |
指定是否将收到的消息自动从队列中删除。 |
凭据服务 |
用于获取 Azure Storage 凭据的控制器服务。 |
消息批处理大小 |
要从队列中检索的消息数量。 |
队列名称 |
Azure Storage 队列的名称 |
请求超时 |
Azure Queue Storage 的读取或写入请求的超时时间。默认为 1 秒。 |
可见性超时 |
检索到的消息对其他使用者不可见的持续时间。 |
proxy-configuration-service |
指定代理配置控制器服务来代理网络请求。在 SOCKS 的情况下，无法保证处理器会使用所选 SOCKS 版本。 |
storage-endpoint-suffix |
公共 Azure 中的存储账户始终使用通用 FQDN 后缀。在某些情况下（例如 Azure Stack 或非公共 Azure 区域），可使用其他后缀替换此端点后缀。 |
关系¶
名称 |
描述 |
|---|---|
success |
所有成功处理的 FlowFiles 都将路由到此关系 |
写入属性¶
名称 |
描述 |
|---|---|
azure.queue.uri |
已配置的“Azure Queue Storage”的绝对 URI |
azure.queue.insertionTime |
将消息插入队列存储的时间 |
azure.queue.expirationTime |
消息在队列存储中过期的时间 |
azure.queue.messageId |
检索到的消息的 ID |
azure.queue.popReceipt |
检索到的消息的弹出接收 |