반응형
머신 런닝등에서 배치잡을 위한 프로그램
아파치꺼
설치과정은 회사 직원분이 설치해 주셔서 모름 ....
바로 스크립트 들어가자
대소문자 따짐 ....
from airflow.models.dag import DAG
from airflow.operators.bash import BashOperator
import datetime
import pendulum
# 한국 시간 timezone 설정
kst = pendulum.timezone("Asia/Seoul")
# 한국 시간 2021년 1월 1일 시작, 오전 8시마다 실행되는 DAG 설정
dag = DAG(
"tutorial",
default_args={
"depends_on_past": True,
"retries": 1,
"retry_delay": datetime.timedelta(minutes=3),
},
start_date=pendulum.datetime(2021, 1, 1, tz=kst),
schedule_interval="0 * * * *",
catchup=False,
)
t1 = BashOperator(
task_id="himari_test_1",
bash_command='echo test1',
dag=dag
)
t2 = BashOperator(
task_id="himari_test_2",
bash_command='echo test2',
dag=dag
)
t1 >> t2