Asset 아울렛으로 데이터 가용성 신호 보내기

여러분의 팀에는 매일 판매 데이터를 s3://data-lake/sales/daily.csv에 저장하는 파이프라인이 있고, 여러 다운스트림 파이프라인이 이 데이터에 의존하고 있습니다. 타이머로 폴링하거나 파일이 준비됐는지 추측하는 대신, Asset 아울렛을 연결해서 작업이 완료되는 즉시 데이터가 업데이트됐다는 신호를 보내도록 설정해 보겠습니다. 이 신호 덕분에 다른 DAG들이 데이터 자체를 기준으로 스케줄을 잡을 수 있습니다.

코드를 완성한 후 파일을 실행하고, Airflow CLI를 사용해 Asset이 등록 및 업데이트되었는지 확인해 보세요.