Bulk

Insert or update entities in an Azure Storage Table.

Make sure to pass either a list of entities or a file with a list of entities.

yaml
type: "io.kestra.plugin.azure.storage.table.Bulk"

Examples

yaml
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 *string

The blob service endpoint.

from *stringarrayobject

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 kestra for internal storage files, file for host local files, and nsfile for namespace files.
A JSON String that will then be serialized either as a single item or a list of items.

table *string

The Azure Storage Table name.

connectionString string

Connection string of the Storage Account.

defaultType string

Default UPSERT_REPLACE

Possible Values

CREATEUPSERT_MERGEUPSERT_REPLACEUPDATE_MERGEUPDATE_REPLACEDELETE

The default operation type to be applied to the entity.

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.

sharedKeyAccountAccessKey string

Shared Key access key for authenticating requests.

sharedKeyAccountName string

Shared Key account name for authenticating requests.

Outputs

count integer

Number of entities created.

Metrics

records.count counter

The total number of entities processed in the bulk operation.

​Bulk

Bulk