tests.system.sqlite.example_sqlite

This is an example DAG for the use of the SQLExecuteQueryOperator with Sqlite. In this example, we create two tasks that execute in sequence. The first task calls an sql command, defined in the SQLite operator, which when triggered, is performed on the connected sqlite database. The second task is similar but instead calls the SQL command from an external file.

Module Contents

tests.system.sqlite.example_sqlite.ENV_ID[source]
tests.system.sqlite.example_sqlite.DAG_ID = 'example_sqlite'[source]
tests.system.sqlite.example_sqlite.create_table_sqlite_task[source]
tests.system.sqlite.example_sqlite.test_run[source]

Was this entry helpful?