Airflow Study5- EmailOperator

박성현·2024년 5월 28일

Airflow

목록 보기
11/28

사전 작업 ( google )

g-mail 내에서
설정 >> 모든 설정 보기 >> 전달 및 POPIMAP
IMAP 액세스 부분 >> IMAP 사용



google 프로필
google 계정관리 >> 보안 >> Google에 로그인 하는 방법 >> 2 단계 인증 >> 앱 비밀번호(앱선택 mail, 기기 아무거나)


Airflow docker-compose.yaml 수정

	AIRFLOW__SMTP__SMTP_HOST: 'smtp.gmail.com'
    AIRFLOW__SMTP__SMTP_USER: 'abcd@gmail.com' # 메일 주소 입력 
    AIRFLOW__SMTP__SMTP_PASSWORD: 'abcdefg12312312' # 위에서 만든 앱 비밀번호 입력 
    AIRFLOW__SMTP__SMTP_PORT: 587
    AIRFLOW__SMTP__SMTP_MAIL_FROM: 'abcd@gmail.com'


dags_email_operator.py

from airflow import DAG 
import datetime
import pendulum

from  airflow.operators.email import EmailOperator


with DAG (
    dag_id = "dags_email_operator",
    schedule="0 0 1 1 *",
    start_date=pendulum.datetime(2023,3,1, tz= "Asia/Seoul"),
    catchup=False
) as dag : 
    
    send_email_task =EmailOperator(
        task_id = "send_email_task",
        to="abcv@naver.com", #받을 사람 주소 
        subject="Airflow", # 제목 
        html_content="Airflow Success" # 내용 
    )
    
profile
다소Good한 데이터 엔지니어

0개의 댓글