GetAzureQueueStorage_v12
Description
Retrieves the messages from an Azure Queue Storage. The retrieved messages will be deleted from the queue by default. If the requirement is to consume messages without deleting them, set 'Auto Delete Messages' to 'false'. Note: There might be chances of receiving duplicates in situations like when a message is received but was unable to be deleted from the queue due to some unexpected situations.
Tags
azure, cloud, dequeue, microsoft, queue, storage
Properties
In the list below required Properties are shown with an asterisk (*). Other properties are considered optional. The table also indicates any default values, and whether a property supports the NiFi Expression Language.
| Display Name | API Name | Default Value | Allowable Values | Description |
|---|---|---|---|---|
| Queue Name * | Queue Name | Name of the Azure Storage Queue Supports Expression Language, using FlowFile attributes and Environment variables. | ||
| Endpoint Suffix * | storage-endpoint-suffix | queue.core.windows.net | Storage accounts in public Azure always use a common FQDN suffix. Override this endpoint suffix with a different suffix in certain circumstances (like Azure Stack or non-public Azure regions). | |
| Credentials Service * | Credentials Service | Controller Service: AzureStorageCredentialsService_v12 Implementations: AzureStorageCredentialsControllerServiceLookup_v12 AzureStorageCredentialsControllerService_v12 | Controller Service used to obtain Azure Storage Credentials. | |
| Auto Delete Messages * | Auto Delete Messages | true |
| Specifies whether the received message is to be automatically deleted from the queue. |
| Message Batch Size * | Message Batch Size | 32 | The number of messages to be retrieved from the queue. | |
| Visibility Timeout * | Visibility Timeout | 30 secs | The duration during which the retrieved message should be invisible to other consumers. | |
| Request Timeout * | Request Timeout | 10 secs | The timeout for read or write requests to Azure Queue Storage. Defaults to 1 second. | |
| Proxy Configuration Service | proxy-configuration-service | Controller Service: ProxyConfigurationService Implementations: StandardProxyConfigurationService | Specifies the Proxy Configuration Controller Service to proxy network requests. Supported proxies: SOCKS, HTTP In case of SOCKS, it is not guaranteed that the selected SOCKS Version will be used by the processor. |
Dynamic Properties
This component does not support dynamic properties.
Relationships
| Name | Description |
|---|---|
| success | All successfully processed FlowFiles are routed to this relationship |
Reads Attributes
This processor does not read attributes.
Writes Attributes
| Name | Description |
|---|---|
| azure.queue.expirationTime | The time when the message will expire from the queue storage |
| azure.queue.insertionTime | The time when the message was inserted into the queue storage |
| azure.queue.messageId | The ID of the retrieved message |
| azure.queue.popReceipt | The pop receipt of the retrieved message |
| azure.queue.uri | The absolute URI of the configured Azure Queue Storage |
State Management
This component does not store state.
Restricted
This component is not restricted.
Input Requirement
This component does not allow an incoming relationship.
System Resource Considerations
This component does not specify system resource considerations.