Airflow Athena CTAS ETL DAG S3에 있는 CSV 데이터를 Athena로 조회하고, 90점 이상 학생만 필터링하여 Parquet 포맷으로 재저장하는 CTAS 기반 ETL 파이프라인전체 파이프라인 흐름[S3 Clean] → [Table Drop] → [CTAS 쿼리 실행] → [완료 감지]매 실행 시 기존 리소스를 초기화(멱등성 보장) 한 뒤, Athena의 CTAS(Create Table As Select)로 데이터를 필터링하여 Parquet 포맷으로 저장하는 구조.1. 모듈 임포트from datetime import datetime, timedeltafrom airflow import DAGfrom airflow.providers.amazon.aws.operators.athena i..