Azure Databricks如何不通过SMTP调用Logic Apps发送条件触发邮件

完全可以实现该需求，整套链路无需使用SMTP协议，核心实现逻辑为：将Logic Apps配置为带鉴权的HTTP触发式工作流，Databricks侧在业务条件命中时直接发起HTTP请求调用Logic Apps端点，由Logic Apps完成最终邮件下发。

一、Logic Apps侧配置步骤 #

• 新建Logic Apps工作流，选择收到HTTP请求时作为第一步触发器，在触发器配置中定义请求体JSON Schema，明确需要传入的字段：收件人列表、邮件主题、邮件正文、是否为HTML格式、附件信息（按需配置），保存触发器后系统会自动生成带签名鉴权的HTTP POST调用地址。
• 在触发器后续追加邮件发送操作：直接选用Logic Apps内置的邮件类连接器即可，比如Office 365 Outlook、SendGrid等商用邮件服务连接器，将HTTP请求传入的字段映射到邮件发送操作的对应参数位置，全程无需配置SMTP服务器地址、端口、账号密码等信息。
• 按需配置访问控制：在Logic Apps的网络设置中配置IP允许规则，仅放行对应Azure Databricks工作区的出口IP段，避免触发接口被恶意调用。
• 配置完成后先做连通性校验：用curl或接口调试工具向生成的HTTP地址发送符合Schema要求的请求，确认邮件可以正常送达，记录好请求地址、请求体格式要求。

二、Databricks侧触发逻辑实现 #

• 不要将Logic Apps的带鉴权调用地址硬编码在代码中，统一存入Databricks Secrets密钥库，调用时通过dbutils.secrets读取，避免密钥泄露。
• 在现有业务判断代码中补充触发逻辑：当预设业务条件满足时，通过计算节点自带的HTTP请求库向Logic Apps地址发送POST请求，传入预先定义的邮件参数即可。
• 增加调用结果校验：如果请求返回非200/202状态码，直接抛出异常，方便作业监控告警。

示例代码（PySpark实现） #

import requests
import json

# 从Databricks密钥库读取Logic Apps触发地址
LA_TRIGGER_URL = dbutils.secrets.get(scope="your-prod-secret-scope", key="mail-send-logic-app-url")

def send_trigger_mail(to_list: list, subject: str, content: str, is_html: bool = True):
    payload = {
        "recipients": to_list,
        "mail_subject": subject,
        "mail_content": content,
        "content_is_html": is_html
    }
    resp = requests.post(
        url=LA_TRIGGER_URL,
        headers={"Content-Type": "application/json"},
        data=json.dumps(payload),
        timeout=10
    )
    if resp.status_code not in [200, 202]:
        raise RuntimeError(f"邮件触发失败，状态码：{resp.status_code}，错误信息：{resp.text}")

# 业务判断逻辑示例
if your_business_condition == True:
    send_trigger_mail(
        to_list=["ops@yourcompany.com", "biz@yourcompany.com"],
        subject="业务告警：XX指标触发阈值",
        content="<p>检测到XX业务指标超过预设阈值，请及时核查处理</p>"
    )

注意事项：如果使用Databricks无服务器计算资源运行作业，需要提前将对应区域无服务器计算的出口IP段加入Logic Apps的IP允许列表，避免调用被网络策略拦截。

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