Tất cả tài liệu

FPT Data Platform

    Hướng dẫn Secret backends
    Hướng dẫn Secret backends
    Updated on 23 Sep 2025

    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

    • Tại giao diện chính, sử dụng thanh tìm kiếm hoặc cuộn để tìm DAG có tên:
      test_vault_secret_backend.

    Bước 4: Bật DAG

    • Bật công tắc (toggle) bên cạnh tên DAG để chuyển sang trạng thái "Enabled" nếu DAG đang bị tắt.

    Bước 5: Khởi chạy DAG

    • Nhấn nút ▶️ Trigger DAG để chạy DAG thủ công.

    Bước 6: Truy cập task

    • Sau khi DAG chạy xong (hoặc đang chạy), click vào tên DAG để vào chi tiết.

    Bước 7: Mở Logs

    • Trong giao diện task instance, chọn tab Logs để xem quá trình thực thi.

    Bước 8: Kiểm tra kết quả

    • Kiểm tra log để xác nhận dữ liệu (biến/secret) đã được đọc thành công từ Vault hoặc Variable.