tests.system.databricks.example_databricks_sql

这是一个示例 DAG,它使用 DatabricksSqlOperator 和 DatabricksCopyIntoOperator。第一个任务创建表并将值插入其中。第二个任务使用 DatabricksSqlOperator 选择数据。第三个任务选择数据并将所选数据的输出存储在指定的文件路径和格式中。第四个任务运行在 test.sql 文件中编写的 select SQL 语句。最后一个任务使用 DatabricksCopyIntoOperator 将数据从传递的 file_location 加载到 Delta 表中。

模块内容

tests.system.databricks.example_databricks_sql.ENV_ID[源代码]
tests.system.databricks.example_databricks_sql.DAG_ID = 'example_databricks_sql_operator'[源代码]
tests.system.databricks.example_databricks_sql.connection_id = 'my_connection'[源代码]
tests.system.databricks.example_databricks_sql.test_run[源代码]

此条目是否有帮助?