原始SQL的氣流

Question

我寧願使用原始的SQL（主要是選擇+插入），而不是O/R映射器，因爲這將是難以進行查詢。

（RDBMS的是postgres9.4）

所以，問題是

我可以使用在氣流邏輯部分原始SQL？

Answer 1

您可以創建一個Postgres數據庫運行原始的SQL直接使用PostgresOperator任務。您需要將Postgres數據庫設置爲Connection object，以便Airflow知道如何連接到數據庫。