Query

id: azure_storage_cosmos_query
namespace: company.team

tasks:
  - id: bulk
    type: io.kestra.plugin.azure.storage.cosmosdb.Query
    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') }}"
    query: "SELECT * FROM c WHERE c.region = 'europe'"
    partitionKeyDefinition:
      paths: ["/region"]
      kind: HASH
      version: V2
    partitionKey:
      region: europe