如何解决Apache Airflow Python DAG中EmailOperator发邮件进入垃圾文件夹问题

需求：根据特定业务条件触发邮件发送，使用Apache Airflow的DAG实现业务流程自动化，通过Python代码调用EmailOperator完成邮件发送功能，实际运行时发送的邮件均被投递到收件人的垃圾邮件文件夹，而非正常收件箱。
相关代码：

EmailOperator(task_id='send_emails', to='abc@testmail.com',
                       subject='This is my mail subject',
                       html_content=" <p>Hi,<br><br>My content<br> <br> Thanks",
                       files=attachment, dag=dag)

配置类优化方案 #

• 检查airflow.cfg中的SMTP配置：
  • 确保smtp_mail_from配置的发件地址和SMTP认证账号完全一致，禁止使用不存在的虚拟发件地址
  • 确认smtp_starttls、smtp_ssl、smtp_port参数和你使用的SMTP服务要求匹配，加密方式配置错误会被判定为伪造邮件
• 企业内部使用场景可联系IT部门将发件IP、发件地址加入内部邮箱白名单，避免内部反垃圾规则拦截
• 若使用自定义域名发件，补充配置SPF、DKIM、DMARC三类域名解析记录，验证发件人合法性，大幅降低被拦截概率

内容类优化方案 #

• 补全HTML邮件的完整结构，不要仅使用零散的标签，当前代码的HTML内容结构不完整是触发拦截的常见原因，调整示例：

html_content="""<html>
  <body>
    <p>Hi,</p>
    <br>
    <p>My content</p>
    <br>
    <p>Thanks</p>
  </body>
</html>"""

• 邮件主题和正文避免出现「测试」「test」「中奖」「返利」等高频垃圾邮件关键词，内容不要有过多的空格、特殊符号
• 若携带附件，避免使用可执行文件、加密压缩包等高风险格式，附件文件名尽量语义化，不要使用无意义的随机字符串

信誉类排查方案 #

• 检查发件IP是否被公共反垃圾组织列入黑名单，公共云服务器IP常存在历史发垃圾邮件的残留黑名单记录，可申请解封后再使用
• 不要短时间内批量发送大量重复内容的邮件，容易被触发频率控制规则判定为垃圾邮件

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