Bước 1: Tạo và upload file Spark vào thư mục mount path cấu hình tại dịch vụ Orchestration
Bước 2: Tạo DAG theo mẫu để cấu hình tới file thực thi đã upload tại bước 1
spark_jobs_dag_with_req_history.py
Bước 3: Upload file DAG chạy Spark vào thư mục dags tại dịch vụ Orchestration
Bước 4: Truy cập, đăng nhập theo đường dẫn Airflow của dịch vụ Orchestration Service để tiến hành chạy DAG