Batch

yaml
type: "io.kestra.plugin.azure.storage.cosmosdb.Batch"

Examples

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
    partitionKeyValue: europe
    tenantId: "{{ secret('AZURE_TENANT_ID') }}"
    clientId: "{{ secret('AZURE_CLIENT_ID') }}"
    clientSecret: "{{ secret('AZURE_CLIENT_SECRET') }}"
    items:
        - id: item_one
          region: europe
          key: value
        - id: item_two
          region: europe
          key: value

Properties

containerId *string

databaseId *string

items *array

SubTypeobject

partitionKeyValue *string

tenantId *string

clientId string

clientSecret string

connectionString string

consistencyLevel string

DefaultSession

Possible Values

STRONGBOUNDED_STALENESSSESSIONEVENTUALCONSISTENT_PREFIX

contentResponseOnWriteEnabled booleanstring

Defaulttrue

endpoint string

pemCertificate string

Outputs

activityId string

diagnostics

Definitions

com.azure.cosmos.CosmosDiagnostics

feedResponseDiagnostics

com.azure.cosmos.implementation.FeedResponseDiagnostics

clientSideRequestStatisticsarray

com.azure.cosmos.implementation.ClientSideRequestStatistics

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

com.azure.cosmos.implementation.query.QueryInfo-QueryPlanDiagnosticsContext

endTimeUTCstring

Formatdate-time

requestTimeline

startTimeUTCstring

Formatdate-time

queryMetricsMapobject

com.azure.cosmos.implementation.QueryMetrics

clientSideMetrics

documentLoadTimestring

Formatduration

documentWriteTimestring

Formatduration

indexHitDocumentCountinteger

indexLookupTimestring

Formatduration

indexUtilizationInfo

outputDocumentCountinteger

outputDocumentSizeinteger

queryPreparationTimes

retrievedDocumentCountinteger

retrievedDocumentSizeinteger

runtimeExecutionTimes

totalQueryExecutionTimestring

Formatduration

samplingRateSnapshotnumber

duration string

Formatduration

errorMessage string

requestCharge number

responseHeaders object

SubTypestring

responseLength integer

results array

Definitions

com.azure.cosmos.models.CosmosBatchOperationResult

effectiveItemSerializer

com.azure.cosmos.CosmosItemSerializer

shouldWrapSerializationExceptionsboolean

requestChargenumber

statusCodeinteger

subStatusCodeinteger

retryAfterDuration string

Formatduration

sessionToken string

statusCode integer

subStatusCode integer

successStatusCode boolean

ServiceNow

Tasks that create, update, read, and delete ServiceNow records via REST.

DataBusiness

Graylog

Enterprise

Export Kestra execution logs to Graylog via GELF HTTP input. Useful for centralized logging and SIEM integrations.

Infrastructure

Prefect

Tasks that trigger Prefect deployments and monitor flow runs.

Data

Batch

More Plugins in this Category

ServiceNow

Graylog

Prefect

2.1.1