Azure Bulk
CertifiedBatch upsert Azure Table entities
Azure Bulk
Batch upsert Azure Table entities
Buffers entities in groups of 100 and submits transactional table batches. Each batch action must share a partition key; rows without a type use defaultType.
type: io.kestra.plugin.azure.storage.table.BulkExamples
id: azure_storage_table_bulk
namespace: company.team
tasks:
- id: bulk
type: io.kestra.plugin.azure.storage.table.Bulk
endpoint: "https://yourstorageaccount.blob.core.windows.net"
connectionString: "DefaultEndpointsProtocol=...=="
table: "table_name"
from:
- partitionKey: "color"
rowKey: "green"
type: "UPSERT_MERGE"
properties:
"code": "00FF00"
Properties
endpoint *Requiredstring
Service endpoint URL
Base HTTPS endpoint of the target service.
from *RequiredNon-dynamicstringarrayobject
Structured data items, either as a map, a list of map, a URI, or a JSON string.
Structured data items can be defined in the following ways:
- A single item as a map (a document).
- A list of items as a list of maps (a list of documents).
- A URI, supported schemes are
kestrafor internal storage files,filefor host local files, andnsfilefor namespace files. - A JSON String that will then be serialized either as a single item or a list of items.
table *Requiredstring
Target Azure table name
Existing Azure Table Storage table to operate on; case-insensitive.
connectionString string
Connection string of the Storage Account.
defaultType string
UPSERT_REPLACECREATEUPSERT_MERGEUPSERT_REPLACEUPDATE_MERGEUPDATE_REPLACEDELETESet default action type
Applied when a row omits type; defaults to UPSERT_REPLACE.
pluginDefaultsRef Non-dynamicstring
Reference (ref) of the pluginDefaults to apply to this task.
sasToken string
The SAS token to use for authenticating requests.
This string should only be the query parameters (with or without a leading '?') and not a full URL.
Outputs
count integer
Number of entities processed
Metrics
records.count counter
The total number of entities processed in the bulk operation.
