[Airflow] E-mail 오퍼레이터

- 이메일 전송해주는 오퍼레이터

email_t1 = EmailOperator(
	task_id="email_t1",
    to='ooooo@naver.com',
    subject="Airflow 처리결과",
    html_content='정상 처리되었습니다.<br/>'

 

- 사전 셋팅 작업

   1) 구글 메일 서버 사용

   2) G-mail -> 설정 -> 모든 설정보기 -> 전달 및 POP/IMAP -> IMAP 사용

   3) 구글 계정관리 -> 보안 -> 2단계 인증 -> 앱비밀번호 셋팅

 

- Docker-compose.yaml 편집 (environment 항목에 추가)

 AIRFLOW__SMTP__SMTP_HOST:'stmp.gmail.com'

 AIRFLOW__SMTP__SMTP_USER:'{gmail 계정}'

 AIRFLOW__SMTP__SMTP_PASSWORD:'{앱비밀번호}'

 AIRFLOW__SMTP__SMTP_PORT:587(고정)

 AIRFLOW__SMTP__SMTP_MAIL_FROM:'{gmail계정}'

 

 

-EMAIL OPERATOR

from airflow import DAG
import pendulum
import datetime
from airflow.operators.email import EmailOperator 

with DAG(
    dag_id = "dags_email_operator",
    schedule="0 8 1 * *",
    start_date=pendulum.datetime(2024, 4, 3, tz="Asia/Seoul"),
    catchup= False
) as dag:
    send_email_task = EmailOperator(
        task_id='send_email_task',
        to='dudgh9477@naver.com', #받을사람
        #cc 참조
        subject= 'Airflow 성공메일',
        html_content='Airflow 작업이 완료되었습니다.'
    )