Queries

yaml
type: "io.kestra.plugin.jdbc.snowflake.Queries"

Examples

yaml
id: snowflake_queries
namespace: company.team

tasks:
  - id: select
    type: io.kestra.plugin.jdbc.snowflake.Queries
    url: jdbc:snowflake://<account_identifier>.snowflakecomputing.com
    username: "{{ secret('SNOWFLAKE_USERNAME') }}"
    password: "{{ secret('SNOWFLAKE_PASSWORD') }}"
    sql: select * from demo_db.public.customers; select * from demo_db.public.emplyees;
    fetchType: FETCH

Properties

sql *string

url *string

afterSQL string

database string

fetchSize integerstring

Default10000

fetchType string

DefaultNONE

Possible Values

STOREFETCHFETCH_ONENONE

parameters object

password string

privateKey string

privateKeyPassword string

queryTag string

role string

schema string

timeZoneId string

transaction booleanstring

Defaulttrue

username string

warehouse string

Outputs

outputs array

Definitions

io.kestra.plugin.jdbc.AbstractJdbcBaseQuery-Output

rowobject

rowsarray

SubTypeobject

sizeinteger

uristring

Formaturi

Metrics

fetch.size counter

Unitrows

PostgreSQL

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

Database

SurrealDB

Tasks that run SurrealQL queries against SurrealDB.

Database

Debezium Microsoft SQL Server

Tasks that stream Microsoft SQL Server change data capture events into Kestra with Debezium.

Database

Queries

More Plugins in this Category

PostgreSQL

SurrealDB

Debezium Microsoft SQL Server

1.5.1