Blueprints

Generate a CSV file report from a SQL query using Trino

Source

yaml
id: trino-query
namespace: company.team

tasks:
  - id: analyze_orders
    type: io.kestra.plugin.jdbc.trino.Query
    url: jdbc:trino://host.docker.internal:8090/tpch
    username: trino
    sql: |
      select orderpriority as priority, sum(totalprice) as total
      from tpch.tiny.orders
      group by orderpriority
      order by orderpriority
    fetchType: STORE

  - id: csv_report
    type: io.kestra.plugin.serdes.csv.IonToCsv
    from: "{{ outputs.analyze_orders.uri }}"

About this blueprint

SQL Outputs

This flow queries data using Trino SQL and generates a downloadable CSV report. To test this integration, you can start Trino in a Docker container: bash docker run -d -p 8090:8080 --name trino trinodb/trino

Query

Ion To Csv

More Related Blueprints

New to Kestra?

Use blueprints to kickstart your first workflows.

Get started with Kestra