Lambda中fetch+signal超时设置未生效问题排查

你遇到的偶发10秒超时，本质是Node.js内置fetch依赖的undici库默认连接超时设置（10秒）覆盖了AbortSignal.timeout(1000)的预期效果。

从日志里的UND_ERR_CONNECT_TIMEOUT错误能看出来，超时发生在TCP连接建立阶段。AbortSignal.timeout()是针对整个请求生命周期的超时，但undici默认的connectTimeout为10000ms，当连接阶段卡住时，undici的连接超时逻辑会优先触发，导致实际等待时间拉到了10秒，而非你设置的1秒。

在fetch配置里显式设置undici的连接超时参数，同时保留AbortSignal.timeout()做双重保险，确保请求在1秒内终止。

修改后的代码示例：

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.handler = void 0;
require("dd-trace/init"); // Needs to come before any instrumented code
const handler = async (event) => {
    const failures = [];
    for (const r of event.Records) {
        let webhookMessage;
        try {
            webhookMessage = JSON.parse(r.body);
        }
        catch (e) {
            console.log("Error in parsing body", r);
        }
        if (!webhookMessage) {
            failures.push({
                itemIdentifier: r.messageId,
            });
            continue;
        }
        try {
            console.time("fetch_url");
            console.log("Fetching URL: ", webhookMessage.configuration.url);
            const res = await fetch(webhookMessage.configuration.url, {
                method: "POST",
                body: JSON.stringify(webhookMessage.data),
                signal: AbortSignal.timeout(1000),
                // 显式覆盖undici默认的10秒连接超时
                connectTimeout: 1000
            });
            if (!res.ok) {
                console.log("URL fetch failed: ", res.status);
                failures.push({
                    itemIdentifier: r.messageId,
                });
            }
        }
        catch (e) {
            console.log("URL fetch failed without response: ", e);
            failures.push({
                itemIdentifier: r.messageId,
            });
        }
        console.timeEnd("fetch_url");
    }
    return {
        batchItemFailures: failures,
    };
};
exports.handler = handler;

如果你的Node.js版本不支持直接在fetch选项中设置connectTimeout，可以手动创建undici Agent实例：

// 先引入undici库（如果未安装，执行npm install undici）
const { Agent } = require('undici');

// 在fetch配置中使用自定义Agent
const res = await fetch(webhookMessage.configuration.url, {
    method: "POST",
    body: JSON.stringify(webhookMessage.data),
    signal: AbortSignal.timeout(1000),
    dispatcher: new Agent({
        connectTimeout: 1000
    })
});

• connectTimeout专门控制TCP连接建立的超时，AbortSignal.timeout()覆盖整个请求生命周期，两者搭配能避免连接阶段的超时延迟。
• Lambda的网络环境偶发的链路延迟可能触发这类问题，但显式设置连接超时可以直接规避。

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