Airflow 上的原始 SQL

Question

我宁愿使用原始 SQL（主要是 select + 插入）而不是 O/R 映射器，因为执行查询会很困难。

(RDBMS为postgres9.4)

所以问题是

我可以将原始 SQL 用于 Airflow 中的逻辑部分吗？

Answer 1

您可以直接使用 PostgresOperator. You will need to set up your Postgres database as a Connection object 在 Postgres 数据库中创建 运行 原始 SQL 的任务，以便 Airflow 知道如何连接到数据库。