BatchBatch
BatchCertified

Batch creates a new Cosmos item and returns its respective Cosmos batch response output.

yaml
type: "io.kestra.plugin.azure.storage.cosmosdb.Batch"
yaml
id: azure_cosmos_container_batch_create_item
namespace: company.team

tasks:
  - id: batch_create
    type: io.kestra.plugin.azure.storage.cosmosdb.Batch
    endpoint: "https://yourcosmosaccount.documents.azure.com"
    databaseId: your_data_base_id
    containerId: your_container_id
    tenantId: "{{ secret('AZURE_TENANT_ID') }}"
    clientId: "{{ secret('AZURE_CLIENT_ID') }}"
    clientSecret: "{{ secret('AZURE_CLIENT_SECRET') }}"
    items:
        - id: item_one
          key: value
        - id: item_two
          key: value
Properties

container ID

databaseId

SubTypeobject

The partition key for all items in the batch.

Tenant ID

Client ID

Client ID of the Azure service principal. If you don't have a service principal, refer to create a service principal with Azure CLI.

Client Secret

Service principal client secret. The tenantId, clientId and clientSecret of the service principal are required for this credential to acquire an access token.

connectionString

DefaultSession
Possible Values
STRONGBOUNDED_STALENESSSESSIONEVENTUALCONSISTENT_PREFIX

consistencyLevel

Represents the consistency levels supported for Azure Cosmos DB client operations in the Azure Cosmos DB service.

Defaulttrue

contentResponseOnWriteEnabled

Sets the boolean to only return the headers and status code in Cosmos DB response in case of Create, Update and Delete operations on CosmosItem. If set to false (which is by default), service doesn't return payload in the response. It reduces networking and CPU load by not sending the payload back over the network and serializing it on the client.

endpoint

PEM Certificate

text
Your stored PEM certificate.
The tenantId, clientId and clientCertificate of the service principal are required for this credential to acquire an access token.
Definitions
feedResponseDiagnostics
clientSideRequestStatisticsarray
activityIdstring
addressResolutionStatisticsobject
contactedReplicasarray
SubTypestring
diagnosticsClientConfig
failedReplicasarray
SubTypestring
gatewayStatisticsListarray
locationEndpointsContactedarray
SubTypestring
metadataDiagnosticsContext
regionsContactedarray
SubTypestring
requestEndTimeUTCstring
Formatdate-time
requestPayloadSizeInBytesinteger
requestStartTimeUTCstring
Formatdate-time
responseStatisticsListarray
retryContext
samplingRateSnapshotnumber
serializationDiagnosticsContext
supplementalResponseStatisticsListarray
diagnosticsContext
endTimeUTCstring
Formatdate-time
requestTimeline
startTimeUTCstring
Formatdate-time
queryMetricsMapobject
clientSideMetrics
documentLoadTimestring
Formatduration
documentWriteTimestring
Formatduration
indexHitDocumentCountinteger
indexLookupTimestring
Formatduration
indexUtilizationInfo
outputDocumentCountinteger
outputDocumentSizeinteger
queryPreparationTimes
retrievedDocumentCountinteger
retrievedDocumentSizeinteger
runtimeExecutionTimes
totalQueryExecutionTimestring
Formatduration
samplingRateSnapshotnumber
Formatduration
SubTypestring
Definitions
effectiveItemSerializer
shouldWrapSerializationExceptionsboolean
requestChargenumber
statusCodeinteger
subStatusCodeinteger
Formatduration

More Plugins in this Category

core
Core Plugins and tasks

Tasks that provide Kestra's built-in orchestration, I/O, and observability capabilities.

CoreStorageScript

111 Tasks

188 Blueprints

SurrealDB
SurrealDB

Tasks that run SurrealQL queries against SurrealDB.

Database

2 Tasks

2 Blueprints

Typesense
Typesense

Tasks that load data into and query Typesense collections.

Database

5 Tasks

OVERVIEW
Versions
1.4.1
Latest
January 21, 2026 Release Notes Min. Compatible Kestra Version: 1.1.0
Previous Versions
1.4.0January 21, 2026 Min. Compatible Kestra Version: 1.1.0
1.3.1December 19, 2025 Min. Compatible Kestra Version: 1.1.0
1.3.0November 19, 2025 Min. Compatible Kestra Version: 1.1.0
1.2.0November 17, 2025 Min. Compatible Kestra Version: 1.1.0
1.1.4November 4, 2025 Min. Compatible Kestra Version: 1.1.0
1.1.3November 4, 2025 Min. Compatible Kestra Version: 1.1.0
1.1.2October 29, 2025 Min. Compatible Kestra Version: 1.0.6
1.1.1October 29, 2025 Min. Compatible Kestra Version: 1.0.6
1.0.2October 29, 2025 Min. Compatible Kestra Version: 1.0.0
1.1.0October 14, 2025 Min. Compatible Kestra Version: 1.0.6
1.0.1October 13, 2025 Min. Compatible Kestra Version: 1.0.0
1.0.0September 8, 2025 Min. Compatible Kestra Version: [1.0,)
0.24.1September 4, 2025 Min. Compatible Kestra Version: [0.24,)
0.24.0August 5, 2025 Min. Compatible Kestra Version: [0.24,)
0.24.0-rc1-SNAPSHOTJuly 31, 2025 Min. Compatible Kestra Version: [0.24,)
0.24.0-rc0-SNAPSHOTJuly 29, 2025 Min. Compatible Kestra Version: [0.23,)
0.23.0June 17, 2025 Min. Compatible Kestra Version: [0.23,0.24)
0.23.0-rc5-SNAPSHOTJune 16, 2025 Min. Compatible Kestra Version: [0.23,0.24)
0.23.0-rc4-SNAPSHOTJune 12, 2025 Min. Compatible Kestra Version: [0.23,0.24)
0.23.0-rc3-SNAPSHOTJune 10, 2025 Min. Compatible Kestra Version: [0.23,0.24)
0.23.0-rc2-SNAPSHOTJune 9, 2025 Min. Compatible Kestra Version: [0.22,)
0.23.0-rc1-SNAPSHOTJune 4, 2025 Min. Compatible Kestra Version: [0.22,)
0.23.0-rc0-SNAPSHOTJune 3, 2025 Min. Compatible Kestra Version: [0.22,)
0.22.3June 3, 2025 Min. Compatible Kestra Version: [0.22,0.23)
0.22.2May 20, 2025 Min. Compatible Kestra Version: [0.22,0.23)
0.22.0April 1, 2025 Min. Compatible Kestra Version: [0.22,)
0.22.0-rc4-SNAPSHOTMarch 31, 2025 Min. Compatible Kestra Version: [0.22,)
0.22.0-rc2-SNAPSHOTMarch 28, 2025 Min. Compatible Kestra Version: [0.22,)
0.22.0-rc1-SNAPSHOTMarch 25, 2025 Min. Compatible Kestra Version: [0.22,)

Created by

Kestra Core Team

Managed by

Kestra Core Team
Plugin Type
CloudMessagingStorageBatchToolDatabase
Links & Resources
GitHub