Bulk Bulk

yaml
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

yaml
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

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
  • Dynamic:
  • Required:

Number of entities created.