Pipedream中邮件内容无法发送至webhook_urls内的Webhook求助

以下是针对你的代码无法发送至目标Webhook的核心问题及修复建议：

1. Payload序列化逻辑冲突 #

send_webhook函数中，你先尝试将邮件文本content反序列化为JSON，失败后直接保留原字符串；但后续调用post_request时默认auto_json_dumps=True，会把字符串再次JSON序列化，导致目标Webhook收到带双引号包裹的字符串内容（比如原文本是alert content，最终发送的是"alert content"），多数Webhook服务无法识别这种格式。

而Discord Webhook正常是因为send_msg_to_dc中手动完成了JSON序列化，并传入auto_json_dumps=False跳过了二次序列化。

修复方法：
根据目标Webhook的格式要求调整：

• 若目标接收纯文本：关闭自动序列化
• 若目标接收JSON：将文本包装为标准JSON对象

修改send_webhook中调用post_request的逻辑：

# 示例1：发送纯文本
response = post_request(webhook_url, payload, auto_json_dumps=False)

# 示例2：发送JSON格式（包装为对象）
payload = {"content": payload}
response = post_request(webhook_url, payload)

2. 重试策略不完整 #

当前Retry仅针对连接失败重试，对请求发送后返回的5xx服务器错误、429限流等场景不会重试，导致临时故障无法自动恢复。

修复方法：
扩展重试策略覆盖常见失败状态码：

retry = Retry(
    connect=3,
    read=3,
    backoff_factor=0.5,
    status_forcelist=[429, 500, 502, 503, 504]
)

3. 缺失请求异常捕获 #

post_request未捕获网络请求可能抛出的异常（如超时、DNS解析失败、连接中断等），这类异常会直接终止代码但不触发日志，导致你看不到报错信息。

修复方法：
在post_request中添加异常捕获并记录日志：

def post_request(webhook_url:str, payload:str or dict, auto_json_dumps:bool = True):
    headers = {
            "Content-Type": "application/json",
            "User-Agent": "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.11 (KHTML, like Gecko) Chrome/23.0.1271.64 Safari/537.11"
        }
    data = json.dumps(payload) if auto_json_dumps else payload
    session = requests.Session()
    retry = Retry(
        connect=3,
        read=3,
        backoff_factor=0.5,
        status_forcelist=[429, 500, 502, 503, 504]
    )
    adapter = HTTPAdapter(max_retries=retry)
    session.mount('http://', adapter)
    session.mount('https://', adapter)
    
    try:
        response = session.post(webhook_url, data=data, headers=headers)
        response.raise_for_status()  # 触发HTTP状态码异常
        return response
    except requests.exceptions.RequestException as e:
        log.error(f"Request failed: {str(e)}\nURL: {webhook_url}\nPayload: {payload}")
        return None

4. URL末尾斜杠可能引发路径不匹配 #

部分Webhook服务对URL路径严格，你的webhook_urls中URL末尾带有/，可能与服务期望的路径不一致。

修复方法：
移除URL末尾的斜杠或确认目标服务的正确路径：

webhook_urls = [
  "https://www.example.com/webhook-1",
  "https://www.example.com/webhook-2",
]

调试建议 #

1. 在post_request中添加打印语句，输出实际发送的payload内容，确认格式是否符合要求：

print(f"Sending to {webhook_url}: {data}")

2. 用Webhook测试工具（如本地调试工具）替换目标URL，确认请求是否真的发出
3. 查看目标Webhook服务的后台日志，排查是否有请求被拒绝的记录

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