SQL
The SQL input component allows you to query data from various input sources using SQL.
Reference to SQL.
Configuration
select_sql
The SQL query statement to execute.
type: string
input_type
The type of input source to query from.
type: enum
options:
avro
arrow
json
csv
parquet
mysql
duckdb
postgres
sqlite
Input Type Configurations
Avro
-
table_name
: Optional table name (used in SQL queries)type:
string
-
path
: Path to Avro filetype:
string
Arrow
-
table_name
: Optional table name (used in SQL queries)type:
string
-
path
: Path to Arrow filetype:
string
Json
-
table_name
: Optional table name (used in SQL queries)type:
string
-
path
: Path to JSON filetype:
string
Csv
-
table_name
: Optional table name (used in SQL queries)type:
string
-
path
: Path to CSV filetype:
string
Parquet
-
table_name
: Optional table name (used in SQL queries)type:
string
-
path
: Path to Parquet filetype:
string
Mysql
-
name
: Optional connection nametype:
string
-
uri
: MySQL connection URItype:
string
-
ssl
:-
ssl_mode
: SSL modetype:
string
-
root_cert
: Optional root certificate pathtype:
string
-
DuckDB
-
name
: Optional connection nametype:
string
-
path
: Path to DuckDB filetype:
string
Postgres
-
name
: Optional connection nametype:
string
-
uri
: PostgreSQL connection URItype:
string
-
ssl
:-
ssl_mode
: SSL modetype:
string
-
root_cert
: Optional root certificate pathtype:
string
-
Sqlite
-
name
: Optional connection nametype:
string
-
path
: Path to SQLite filetype:
string
Examples
- input:
type: "sql"
select_sql: "SELECT * FROM table"
input_type:
mysql:
name: "my_mysql"
uri: "mysql://user:password@localhost:3306/db"
ssl:
ssl_mode: "verify_identity"
root_cert: "/path/to/cert.pem"