Initial Setup
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ả