Bulk Bulk

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

Inserts or update an entities into the table.

# Examples

id: "bulk"
type: "io.kestra.plugin.azure.storage.table.Bulk"
endpoint: "https://yourblob.blob.core.windows.net"
connectionString: "DefaultEndpointsProtocol=...=="
table: "mydata"
from:
  partitionKey: "color"
  rowKey: "green"
  type: "UPSERT_MERGE"
  properties:
    "code": "00FF00"

# Properties

# connectionString

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

Connection string of the storage account.

# 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.

Can be an internal storage uri, a map or a list.with the following format: partitionKey, rowKey, properties

# endpoint

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

The blob service endpoint.

additionally parses it for information (SAS token)

# from

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

Source of message send

Can be an internal storage uri, a map or a list.with the following format: partitionKey, rowKey, type, properties

# 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

# table

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

The table name

# Outputs

# count

  • Type: integer

Number of entity created