tests.system.sqlite.example_sqlite

这是使用带有 Sqlite 的 SQLExecuteQueryOperator 的示例 DAG。在这个例子中,我们创建了两个按顺序执行的任务。第一个任务调用在 SQLite 操作符中定义的 sql 命令,当触发时,该命令将在连接的 sqlite 数据库上执行。第二个任务类似,但改为从外部文件调用 SQL 命令。

模块内容

tests.system.sqlite.example_sqlite.ENV_ID[源代码]
tests.system.sqlite.example_sqlite.DAG_ID = 'example_sqlite'[源代码]
tests.system.sqlite.example_sqlite.create_table_sqlite_task[源代码]
tests.system.sqlite.example_sqlite.test_run[源代码]

此条目是否有帮助?