Bước 1: Trong thư mục `dags` theo mount S3 path có file read_vault_be.py
from airflow import DAG from airflow.operators.python import PythonOperator from airflow.models import Variable from datetime import datetime from pprint import pprint def read_secret(): secret = Variable.get("myvar") pprint(Variable) print(f"Secret from Vault: {secret}") with DAG( dag_id="test_vault_secret_backend", start_date=datetime(2023, 1, 1), schedule_interval=None, catchup=False ) as dag: read_secret_task = PythonOperator( task_id="read_secret", python_callable=read_secret )
Bước 2: Đăng nhập vào Airflow UI
Mở trình duyệt và truy cập URL Airflow đã được cung cấp.
Đăng nhập bằng username và password (nếu có yêu cầu xác thực).
Bước 3: Tìm DAG cần chạy
Bước 4: Bật DAG
Bước 5: Khởi chạy DAG
Bước 6: Truy cập task
Bước 7: Mở Logs
Bước 8: Kiểm tra kết quả