How to Integrate Oracle with Airflow

Why How to Integrate Oracle with Airflow is important

high_value_new_customers = OracleOperator(
    task_id='high_value_new_customers',
    oracle_conn_id='oracle_default',
    sql="""
        SELECT C.id, C.name, C.email, O.total_amount
        FROM Customers C
        JOIN Orders O ON O.customer_id = C.id
        WHERE C.created_at >= SYSDATE - 1
          AND O.total_amount > 500
    """
)

# 1. Add an Oracle connection
$ airflow connections add 'oracle_default' \
  --conn-type oracle \
  --conn-login scott \
  --conn-password tiger \
  --conn-host db.example.com \
  --conn-port 1521 \
  --conn-schema ORCLPDB1 \
  --conn-extra '{"service_name":"ORCLPDB1"}'

# 2. Define a DAG that queries Orders
from airflow import DAG
from airflow.providers.oracle.operators.oracle import OracleOperator
from datetime import datetime, timedelta

default_args = {
    'owner': 'galaxy',
    'retries': 3,
    'retry_delay': timedelta(minutes=5)
}

with DAG(
    dag_id='daily_high_value_orders',
    start_date=datetime(2023, 1, 1),
    schedule_interval='0 2 * * *',
    catchup=False,
    default_args=default_args
) as dag:
    high_value_orders = OracleOperator(
        task_id='high_value_orders',
        oracle_conn_id='oracle_default',
        sql="""
            SELECT *
            FROM Orders
            WHERE total_amount > :min_total
              AND order_date >= TRUNC(SYSDATE) - 1
        """,
        parameters={'min_total': 1000}
    )