Operator가 사용할 동적 환경 변수 내보내기
Operator가 사용할 동적 환경 변수 내보내기
airflow_local_settings.py에 정의한 get_airflow_context_vars가 반환하는 key/value 쌍이 기본 Airflow context 환경 변수에 주입되어, 태스크 실행 시 환경 변수로 사용할 수 있어요. key와 value 모두 문자열이어야 한다는 점을 꼭 기억해 두세요.
출처: 문서
본문
airflow_local_settings.py에 정의된 get_airflow_context_vars가 반환하는 key/value 쌍은 기본 Airflow context 환경 변수에 주입되어, 태스크 실행 시 환경 변수로 사용할 수 있어요. 참고로 key와 value는 둘 다 문자열이어야 해요.
dag_id, task_id, execution_date, dag_run_id, dag_owner, dag_email은 예약된(reserved) 키예요.
예를 들어 airflow_local_settings.py 파일에 이렇게 작성할 수 있어요:
def get_airflow_context_vars(context) -> dict[str, str]:
"""
:param context: The context for the task_instance of interest.
"""
# more env vars
return {"airflow_cluster": "main"}
로컬 설정을 구성하는 방법에 대한 자세한 내용은 로컬 설정 구성을 확인해 보세요.