Airflow 2.0.2版本EmailOperator如何配置Reply-To参数？

Airflow 2.0.2版本的EmailOperator不存在default_param参数，传入该参数会触发无效参数异常。同时该版本的EmailOperator默认未暴露传递额外邮件头（如Reply-To）的接口，尽管底层调用的send_email函数支持这类参数，但Operator本身没有传递逻辑。

方案1：自定义EmailOperator #

继承原EmailOperator，添加传递邮件头的逻辑：

from airflow.operators.email import EmailOperator
from airflow.utils.email import send_email

class CustomEmailOperator(EmailOperator):
    def __init__(self, headers=None, *args, **kwargs):
        super().__init__(*args, **kwargs)
        self.headers = headers or {}

    def execute(self, context):
        send_email(
            to=self.to,
            subject=self.subject,
            html_content=self.html_content,
            files=self.files,
            cc=self.cc,
            bcc=self.bcc,
            mime_subtype=self.mime_subtype,
            mime_charset=self.mime_charset,
            conn_id=self.conn_id,
            **self.headers
        )

使用自定义Operator：

email_op = CustomEmailOperator(
    task_id='send_email',
    to=destination['emails'],
    subject=destination['subject'],
    html_content=destination['message'],
    files=[file.name],
    headers={'Reply-To': 'reply_to@example.com'},
)
email_op.execute(context)

方案2：直接调用send_email函数 #

绕过EmailOperator，直接使用底层的send_email函数，它支持直接传递Reply-To这类邮件头参数：

from airflow.utils.email import send_email

send_email(
    to=destination['emails'],
    subject=destination['subject'],
    html_content=destination['message'],
    files=[file.name],
    Reply-To='reply_to@example.com'
)

内容的提问来源于stack exchange，提问作者Kundan Kumar