airflow.providers.smtp.notifications.smtp

属性

send_smtp_notification

类

SmtpNotifier

SMTP 通知器。

模块内容

类 airflow.providers.smtp.notifications.smtp.SmtpNotifier(to, from_email=None, subject=None, html_content=None, files=None, cc=None, bcc=None, mime_subtype='mixed', mime_charset='utf-8', custom_headers=None, smtp_conn_id=SmtpHook.default_conn_name, *, template=None)[source]

继承自： airflow.providers.common.compat.notifier.BaseNotifier

SMTP 通知器。

接受关键字参数。唯一必需的参数是 from_email 和 to。示例

EmptyOperator(task_id="task", on_failure_callback=SmtpNotifier(from_email=None, to="my@mail.com"))

EmptyOperator(
    task_id="task",
    on_failure_callback=SmtpNotifier(
        from_email="myemail@myemail.com",
        to="myemail@myemail.com",
        subject="Task {{ ti.task_id }} failed",
    ),
)

您可以在 SMTP 连接配置中定义主题和 HTML 内容的默认模板。

参数：

smtp_conn_id (str) – 该 smtp 连接 ID 包含用于认证客户端的信息。

template_fields = ('from_email', 'to', 'subject', 'html_content', 'files', 'cc', 'bcc', 'mime_subtype',...[source]
smtp_conn_id = 'smtp_default'[source]
from_email = None[source]
to[source]
files = None[source]
cc = None[source]
bcc = None[source]
mime_subtype = 'mixed'[source]
mime_charset = 'utf-8'[source]
custom_headers = None[source]
subject = None[source]
html_content = None[source]
属性 hook: airflow.providers.smtp.hooks.smtp.SmtpHook[source]

SMTP 事件 Hook。

notify(context)[source]

通过 SMTP 服务器发送电子邮件。

airflow.providers.smtp.notifications.smtp.send_smtp_notification[source]

此条目有帮助吗？