airflow.providers.oracle.example_dags.example_oracle_fetch¶

Attributes¶

`DOC`
`start`

Functions¶

`fetch_rows`()	Fetch sample rows from Oracle table DEMO_TABLE.
`print_rows`([ti])	Print rows pulled from Oracle.

Module Contents¶

airflow.providers.oracle.example_dags.example_oracle_fetch.DOC = Multiline-String[source]¶

Show Value

"""
### Example: Simple Oracle fetch

This DAG demonstrates using `OracleHook` to read from Oracle and push rows
into XCom for downstream tasks. Adapt this pattern for your transfers.

**Prereqs**
- Define a connection `oracle_default` in Airflow.
- Ensure a table `demo_table(id NUMBER, name VARCHAR2(100))` exists (or edit the SQL).
"""

airflow.providers.oracle.example_dags.example_oracle_fetch.fetch_rows()[source]¶: Fetch sample rows from Oracle table DEMO_TABLE.

airflow.providers.oracle.example_dags.example_oracle_fetch.print_rows(ti=None)[source]¶: Print rows pulled from Oracle.

airflow.providers.oracle.example_dags.example_oracle_fetch.start[source]¶