TrinoOperator
TrinoExecutes sql code using a specific Trino query Engine.
Access Instructions
Install the Trino provider package into your Airflow environment.
Import the module into your DAG file and instantiate it with your desired params.
Parameters
sqlthe SQL code to be executed as a single string, or a list of str (sql statements), or a reference to a template file.
trino_conn_idid of the connection config for the target Trino environment
autocommitWhat to set the connection’s autocommit setting to before executing the query
handlerThe result handler which is called with the result of each statement.
parameters(optional) the parameters to render the SQL query with.
Documentation
Executes sql code using a specific Trino query Engine.
See also
For more information on how to use this operator, take a look at the guide: TrinoOperator