Bulk

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

Inserts or updates entities into the Azure Storage Table. Make sure to pass either a list of entities or a file with a list of entities.

Examples

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

defaultType

• Type: string
• Dynamic: ✔️
• Required: ✔️
• Default: UPSERT_REPLACE
• Possible Values:
  • CREATE
  • UPSERT_MERGE
  • UPSERT_REPLACE
  • UPDATE_MERGE
  • UPDATE_REPLACE
  • DELETE

The default operation type to be applied to the entity.

endpoint

• Type: string
• Dynamic: ✔️
• Required: ✔️

The blob service endpoint.

from

• Type: object
• Dynamic: ✔️
• Required: ✔️

Source of a message.

Can be an internal storage URI or a list of maps in the format partitionKey, rowKey, type, properties, as shown in the example.

table

• Type: string
• Dynamic: ✔️
• Required: ✔️

The Azure Storage Table name.

connectionString

• Type: string
• Dynamic: ✔️
• Required: ❌

Connection string of the Storage Account.

sasToken

• Type: string
• Dynamic: ✔️
• Required: ❌

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

• Type: string
• Dynamic: ✔️
• Required: ❌

Shared Key access key for authenticating requests.

sharedKeyAccountName

• Type: string
• Dynamic: ✔️
• Required: ❌

Shared Key account name for authenticating requests.

Outputs

count

• Type: integer
• Required: ❌

Number of entities created.

Definitions