1. Python -> Email 오퍼레이터 Xcom 전달

• Email 오퍼레이터는 어떤 파라미터에 Template을 쓸 수 있는가?
• https://airflow.apache.org/docs/apache-airflow/stable/_api/airflow/operators/email/index.html#airflow.operators.email.EmailOperator
  

2. 실습

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

with DAG(
    dag_id="dags_python_email_xcom",
    schedule="10 0 * * *",
    start_date=pendulum.datetime(2023, 3, 1, tz="Asia/Seoul"),
    catchup=False,
) as dag:

    @task(task_id="something_task")
    def some_logic(**kwargs):
        from random import choice

        return choice(["Success", "Fail"])

    send_email = EmailOperator(
        task_id="send_email",
        to="tkddnr961224@gmail.com",
        subject='{{ data_interval_end.in_timezone("Asia/Seoul") | ds}} some_logic 처리 결과',
        html_content='{{ data_interval_end.in_timezone("Asia/Seoul") | ds }} 처리 결과는 <br> \
            {{ti.xcom_pull(task_ids="something_task")}} 했습니다 <br>',
    )
    some_logic() >> send_email