AWS AppSync查询更新后DynamoDB表失败问题排查求助

核心问题 #

你的Lambda函数在创建条目后，再次执行时通过AppSync查询不到刚创建的条目，导致重复创建；重新上传代码后恢复正常。这大概率是Lambda执行环境复用+AppSync客户端缓存/一致性配置共同导致的问题。

可能的原因及修复方案 #

1. AppSync客户端全局初始化导致缓存残留 #

Lambda的执行环境会被复用，若你在代码全局作用域初始化了AppSync客户端（比如client变量定义在全局），客户端内部的缓存会被保留，第二次执行查询时会直接返回缓存的旧数据，而非实时查询DynamoDB。

修复：
将AppSync客户端的初始化移到handler函数内部，每次请求都创建新的客户端实例，避免缓存复用：

// 不要在全局作用域初始化client
export async function handler(event, context) {
    // 每次处理请求时创建新的AppSync客户端
    const client = new AWSAppSyncClient({
        url: process.env.APPSYNC_API_URL,
        region: process.env.AWS_REGION,
        auth: {
            type: 'AWS_IAM',
            credentials: AWS.config.credentials
        },
        disableOffline: true // 禁用离线缓存，避免本地缓存干扰
    });

    console.log("List item in DB");
    var items = await getItems(event.iccid, event.imei, client); // 传入client

    if (items.length == 0) {
        console.log("No item found");
        await createItem(event, client); // 传入client
    } else {
        console.log("Item already exist");
        console.log(items[0]);
    }
}

// 修改getItems和createItem，接收client参数
async function getItems(iccid, imei, client) {
    const queryObj = getItemObj;
    // ... 原有逻辑，使用传入的client执行查询
}

async function createItem(event, client) {
    const mutationObj = createItemObj;
    // ... 原有逻辑，使用传入的client执行创建
}

2. AppSync查询使用最终一致性，新创建条目未及时返回 #

AppSync默认的DynamoDB数据源查询是最终一致性，刚写入的数据可能需要短暂时间才能被查询到。Lambda执行速度快，可能在写入完成后立即查询，此时数据还未同步。

修复：
在查询时指定consistency: 'STRONG'，强制使用强一致性查询：

// 在getItems的query调用中添加参数
const { data } = await client.query({
    query: queryObj,
    variables: variables,
    consistency: 'STRONG' // 强一致性查询，确保读取最新数据
});

3. 跳过客户端缓存，强制请求服务端 #

即使客户端是新创建的，部分AppSync客户端默认会启用缓存，通过设置fetchPolicy: 'network-only'可以强制每次查询都直接请求服务端，不使用本地缓存：

// 在query调用中添加fetchPolicy参数
const { data } = await client.query({
    query: queryObj,
    variables: variables,
    fetchPolicy: 'network-only' // 跳过缓存，直接请求服务端
});

4. 避免手动指定_version字段 #

你在创建条目时手动指定了_version: 1，若使用了AppSync的冲突检测（DynamoDB版本控制），建议让AppSync自动生成版本号，而非手动指定，避免潜在的版本冲突或数据不一致：

// 修改createItem的variables，移除手动指定的_version
const variables = {
    iccid: event.iccid,
    imei: event.imei
    // 移除_version: 1，让AppSync自动生成
};

验证步骤 #

1. 修复后多次执行Lambda函数，查看CloudWatch日志中的查询结果，确认能正确返回已创建的条目。
2. 检查DynamoDB表，确认不会再生成重复条目。

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