[TIL 6/7] Airflow Day 3

Airflow Decorators

from airflow.decorators import task
from airflow import DAG

@task
def print_hello():
	print("hello!")
    return "hello!"

@task
def print_goodbye():
# ...

with DAG(
# ...
) as dag:

print_hello() >> print_goodbye() # 함수 이름이 task ID가 됨

Docker에 파이썬 모듈 설치하기

내가 까먹을까봐 적어두는 글
1. $ docker ps 하면 목록 다 뜸
2. $ docker exec -it {CONTAINER_ID} sh 원하는 컨테이너 ID 입력해서 shell script 실행하고
3. $ pip3 install yfinance 거기에서 예를 들어 이렇게 설치

[참고] root user로 로그인 하는 방법: $ docker exec --user root -it {CONTAINER_ID} sh

기타

dags 폴더에서 코딩할 때 주의할 점

• Airflow는 dags 폴더를 주기적으로 스캔
  • DAG 모듈이 들어있는 모든 파일들의 main 함수가 실행이 됨 → 의도하지 않았지만, 테스트 코드까지 실행될 수 있음

Time Zone

타임존은 UTC 권장