Azure Blob Storage
Micro-Integration Flows using Azure Blob Storage can be configured as a source only.
To configure the connection details for Azure Blob Storage in your Micro-Integration, see Azure Blob Storage Connection Parameters
You must also define at least one Micro-Integration Flow that specifies:
-
the endpoints where data is consumed from and published to. For more information, see Micro-Integration Flow Parameters.
-
how the header and payload fields should be mapped. For more information, see Mapping Headers and Payloads
For a listing of available message headers, see Azure Blob Storage Message Headers.
Azure Blob Storage Connection Parameters
These parameters are configured at the Micro-Integration level and are shared across all Micro-Integration Flows using this Micro-Integration.
| Field | Description |
|---|---|
|
Delete After Read |
Select to delete the file after reading. |
|
Checkpoint Queue |
The name of the Last Value Queue to use as checkpoint storage. |
|
Auto Create Checkpoint Queue |
Select to automatically create the checkpoint queue if it does not exist. |
Micro-Integration Flow Parameters
You must configure the endpoint parameters for each Flow. Each Flow can have different settings, but they all share the connection details of the parent Micro-Integration.
Azure Blob Storage Source Parameters
The following table describes the parameters for configuring Azure Blob Storage as a source.
| Field | Description |
|---|---|
|
Azure Storage Blob Service URI |
The URI of the Azure Blob Storage data source, including the account and container name. Format: |
|
Azure Account Access key |
An access key for the associated Azure account name to be used for authentication with Azure Blob Storage services. Format: |
|
File Format |
The format of the files coming from the Azure Blob Storage service:
|
|
Additional Properties |
Additional properties for the Azure Blob Storage service. For example, |
Delimited File Configuration Properties
| Field | Description |
|---|---|
|
Event Delimiter |
The delimiter used to separate the events in the file. The default value is |
|
Field Delimiter |
The delimiter used to separate the fields in each event. The default value is |
JSON File Configuration Properties
| Field | Description |
|---|---|
|
JSON Path Filter Expression |
The JSON Path expression to filter or split the JSON file. The default value is |
XML File Configuration Properties
| Field | Description |
|---|---|
|
XPath Filter Expression |
The XPath expression to filter or split the XML file. The default value is |
Additional Properties
| Option | Type | Default | Description |
|---|---|---|---|
|
blobName |
String |
None |
The name of the blob to consume from a container. On the producer, this parameter is required only for blob-level operations. |
|
blobOffset |
long |
|
The blob offset for upload or download operations. |
|
closeStreamAfterRead |
boolean |
|
When true, indicates that the stream closes after a read operation. |
|
dataCount |
Long |
None |
The number of bytes to include in the range. This value must be greater than or equal to 0 if you specify it. |
|
fileDir |
String |
None |
The file directory where downloaded blobs are saved. You can use this parameter in both producer and consumer configurations. |
|
maxResultsPerPage |
Integer |
None |
The maximum number of blobs to return, including all BlobPrefix elements. If the request does not specify |
|
maxRetryRequests |
int |
|
The maximum number of additional HTTP Get requests that are made while reading data from a response body. |
|
prefix |
String |
None |
A filter that returns only blobs whose names begin with the specified prefix. This parameter can be null to return all blobs. |
|
regex |
String |
None |
A filter that returns only blobs whose names match the specified regular expression. This parameter can be null to return all blobs. If you set both |
|
sasToken |
String |
None |
A Shared Access Signature (SAS) token for authentication with Azure Blob Storage. |
| blobSequenceNumber |
Long |
|
A user-controlled value that you can use to track requests. The sequence number value must be between 0 and 263 - 1. |
|
closeStreamAfterWrite |
boolean |
|
When true, indicates that the stream closes after a write operation. |
|
commitBlockListLater |
boolean |
|
When true, indicates that staged blocks are not committed directly. |
|
createAppendBlob |
boolean |
|
When true, indicates that append blocks are created when committing append blocks. |
|
createPageBlob |
boolean |
|
When true, indicates that the page blob is created when uploading a page blob. |
|
downloadLinkExpiration |
Long |
None |
The expiration time in milliseconds that overrides the default expiration for the URL download link. |
|
pageBlobSize |
Long |
|
The maximum size for the page blob, up to 8 TB. The page blob size must be aligned to a 512-byte boundary. |
|
backoffErrorThreshold |
int |
None |
The number of subsequent error polls that must occur before the |
|
backoffIdleThreshold |
int |
None |
The number of subsequent idle polls that must occur before the |
|
backoffMultiplier |
int |
None |
A multiplier that allows the scheduled polling consumer to back off if there has been a number of subsequent idle polls or errors in a row. The multiplier represents the number of polls that are skipped before the next actual attempt occurs. When you use this option, you must also configure |
|
delay |
long |
|
The number of milliseconds before the next poll. |
|
greedy |
boolean |
|
When true, indicates that the ScheduledPollConsumer runs immediately again if the previous run polled one or more messages. |
|
initialDelay |
long |
1000
|
The number of milliseconds before the first poll starts. |
|
repeatCount |
long |
|
The maximum number of times the scheduler fires. For example, if you set this parameter to 1, the scheduler fires only once. If you set it to 5, the scheduler fires five times. A value of zero or a negative value means the scheduler fires indefinitely. |
|
useFixedDelay |
boolean |
|
When true, indicates that fixed delay is used rather than fixed rate. See ScheduledExecutorService in the JDK for details. |
|
sourceBlobAccessKey |
String |
None |
The access key for the source blob in a copy blob operation. Because passing an access key as a header is unsafe, you can set it as a parameter instead. |
|
credentials |
Object |
None |
Credentials object for authentication with Azure Blob Storage. |
|
credentialType |
String |
None |
The type of credential to use for authentication (e.g., AZURE_IDENTITY, AZURE_SAS, SHARED_ACCOUNT_KEY). |