Microsoft Fabric Query

Microsoft Fabric Query
Certified
Query a Microsoft Fabric Warehouse

Executes a SQL query against a Microsoft Fabric Warehouse over JDBC using Active Directory service principal authentication. Supports STORE (writes to Kestra internal storage as ION) and FETCH (returns rows as a list).

yaml
type: io.kestra.plugin.microsoft.fabric.warehouse.Query

Examples

yaml
id: fabric_warehouse_query
namespace: company.team

tasks:
  - id: query
    type: io.kestra.plugin.microsoft.fabric.warehouse.Query
    tenantId: "{{ secret('FABRIC_TENANT_ID') }}"
    clientId: "{{ secret('FABRIC_CLIENT_ID') }}"
    clientSecret: "{{ secret('FABRIC_CLIENT_SECRET') }}"
    sqlEndpointId: "your-sql-endpoint-id"
    warehouseId: "your-warehouse-id"
    sql: "SELECT TOP 100 * FROM dbo.sales"
    fetchType: STORE

Properties

sql *string

SQL query

SQL statement to execute against the warehouse

sqlEndpointId *string

SQL Endpoint ID

Unique identifier of the Fabric Warehouse SQL endpoint, used as the JDBC server hostname (.datawarehouse.fabric.microsoft.com). Find it in the Fabric portal: open your Warehouse → Settings → SQL endpoint → copy the unique identifier from the SQL connection string.

warehouseId *string

Warehouse ID

Microsoft Fabric Warehouse item GUID, used as the JDBC database name

clientId string

Client ID

Service principal client (application) ID

clientSecret string

Client Secret

Service principal client secret. When both clientId and clientSecret are provided, service principal authentication is used; otherwise DefaultAzureCredential is used.

fetchType string

DefaultSTORE

Possible Values

STOREFETCHFETCH_ONENONE

Fetch type

How to return results: STORE writes an ION file to Kestra storage; FETCH returns rows as a list (not recommended for large result sets)

pluginDefaultsRef string

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

tenantId string

Tenant ID

Azure Active Directory tenant ID for authentication

Outputs

row object

Row

Single result row when fetchType=FETCH_ONE

rows array

SubTypeobject

Rows

Result rows when fetchType=FETCH

size integer

Default0

Row count

Number of rows returned

uri string

Formaturi

Storage URI

Kestra internal storage URI of the ION file when fetchType=STORE

Metrics

rows counter

Number of rows returned by the query

Clickhouse

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

Data

Weaviate

Tasks that manage and query vectors in Weaviate.

DataAI

Microsoft Fabric QueryCertifiedQuery a Microsoft Fabric Warehouse

Microsoft Fabric Query

More Plugins in this Category

Clickhouse

Weaviate

Microsoft Fabric Query
Certified
Query a Microsoft Fabric Warehouse