Azure Query

Azure Query

Certified

Execute a single SQL query against Azure HorizonDB

Runs one SQL statement over a JDBC connection and returns results according to fetchType (FETCH, FETCH_ONE, STORE, or NONE).

yaml
type: io.kestra.plugin.azure.horizondb.Query
yaml
id: horizondb_query
namespace: company.team

inputs:
  - id: host
    type: STRING

tasks:
  - id: query
    type: io.kestra.plugin.azure.horizondb.Query
    host: "{{ inputs.host }}"
    port: 5432
    database: mydb
    username: "{{ secret('HORIZONDB_USERNAME') }}"
    password: "{{ secret('HORIZONDB_PASSWORD') }}"
    sql: |
      SELECT id, total, status FROM orders WHERE loaded_at > now() - INTERVAL '1 day'
    fetchType: STORE
Properties

Database name

HorizonDB server host

Hostname of the Azure HorizonDB server, without protocol or port (e.g. myserver.postgres.horizondb.azure.com).

SQL statement to execute

A single SQL statement, rendered with flow variables before execution.

Azure client id

Used with tenantId/clientSecret for service principal authentication when useEntraId is true. Ignored otherwise.

Azure client secret

Used with tenantId/clientId for service principal authentication when useEntraId is true. Ignored otherwise.

Default10000

JDBC fetch size

Number of rows fetched per database round trip; only used for STORE mode.

DefaultNONE
Possible Values
STOREFETCHFETCH_ONENONE

Result fetching mode

FETCH returns all rows, FETCH_ONE returns the first row only, STORE streams rows to internal storage (ION), NONE returns no rows.

Password

Required unless useEntraId is true.

Reference (ref) of the pluginDefaults to apply to this task.

Default5432

HorizonDB server port

Defaults to the standard PostgreSQL port.

Defaulttrue

Require TLS

When true (the default), the connection is rejected unless it is encrypted (sslmode=require). Set to false only for local development against a non-TLS instance.

Azure tenant id

Used with clientId/clientSecret for service principal authentication when useEntraId is true. Ignored otherwise.

Defaultfalse

Authenticate with Azure Entra ID

When true, authenticates using Azure Entra ID (via the Azure Identity Extensions JDBC plugin) instead of a static password. With no further properties set, this falls back to whatever DefaultAzureCredential resolves on the worker (managed identity, environment variables, Azure CLI login, etc.); set tenantId/clientId/clientSecret below to authenticate as a specific service principal instead.

Username

Required unless useEntraId is true and the Entra ID token carries the identity.

First row of fetched data

Only populated when fetchType is FETCH_ONE.

SubTypeobject

All fetched rows

Only populated when fetchType is FETCH.

Number of rows fetched or stored

Populated when fetchType is FETCH, FETCH_ONE, or STORE.

Rows affected

Populated when the statement did not return a result set (e.g. INSERT, UPDATE, DELETE, DDL).

Formaturi

URI of stored results in internal storage

Only populated when fetchType is STORE; stored using ION format.

Unitrows

The number of fetched or stored rows.

More Plugins in this Category

Liquibase
Liquibase

Tasks that run Liquibase change management commands.

Data

2 tasks

6 blueprints

PostgreSQL
PostgreSQL

Tasks that connect to PostgreSQL via JDBC to run queries and loads.

Data

6 tasks

25 blueprints