Asset 기반 스케줄링 직접 확인하기
이전 연습 문제에서 작성한 sales_producer와 sales_consumer DAG가 Airflow UI에 로드되어 있습니다. 프로듀서는 판매 데이터를 기록하고 s3://data-lake/sales/daily.csv Asset을 업데이트합니다. 컨슈머는 해당 Asset을 기반으로 스케줄링되어 있습니다.
아래 단계를 따라 진행해 보세요.
- DAGs 뷰에서
sales_producer와sales_consumer를 찾아 토글 스위치로 활성화하세요. - 재생 아이콘을 클릭하고 Single Run, Trigger를 선택해
sales_producer를 트리거하세요. - 프로듀서 실행이 완료될 때까지 기다리세요(모든 태스크가 초록색으로 표시되어야 합니다).
- 아무것도 클릭하지 않았는데도
sales_consumer가 자동으로 트리거되었는지 확인하세요.
sales_producer 실행이 완료된 후 sales_consumer에는 어떤 일이 발생하나요?
이 연습은 강의의 일부입니다
