jobs - 气流上的原始 SQL

Question

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

（RDBMS 是 postgres9.4）

所以问题是

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

Answer 1

您可以直接使用PostgresOperator创建在 Postgres 数据库中运行原始 SQL 的任务。您需要将 Postgres 数据库设置为Connection 对象，以便 Airflow 知道如何连接到数据库。