DynamoDB控制台与Node文档客户端相同查询返回结果不一致问题

我使用DDB文档客户端执行以下Query命令：

const queryCommand = new QueryCommand({
        TableName: TABLE_NAME,
        IndexName: "gsi1",
        KeyConditionExpression: `gsi1_pk = :type`,
        FilterExpression: `contains(customerName, :client) AND isLatest = :isLatestFlag`,
        ExpressionAttributeValues: {
            ":type": "report",
            ":client": "JACK SMITH",
            ":isLatestFlag": "true",
        },
    });
const latest = await docClient.send(queryCommand);

执行后仅返回1条数据，但数据库中实际有2条符合条件的数据，且在DynamoDB控制台执行相同查询能返回这2条数据。

更奇怪的是：数据库初始填充测试数据时，该Query能正常返回2条数据；但一旦更新其中一个数据项（仅修改了与查询无关的sk和gsi1_sk字段，均为时间戳），文档客户端的Query就不再返回该数据项。

换成带过滤条件的Scan命令能正确返回2条数据，但生产环境不想使用Scan：

const scanCommand = new ScanCommand({
        TableName: TABLE_NAME,
        FilterExpression: `contains(customerName, :client) AND isLatest = :isLatestFlag AND gsi1_pk = :type`,
        ExpressionAttributeValues: {
            ":type": "report",
            ":client": customerNameUppercase,
            ":isLatestFlag": "true",
        },
    });

我的DDB Schema如下：

{
                fields: {
                    pk: "string", // report uuid | advisor email
                    sk: "string",
                    gsi1_pk: "string",
                    gsi1_sk: "string",
                    isLatest: "string",
                },
                primaryIndex: {
                    partitionKey: "pk",
                    sortKey: "sk",
                },
                globalIndexes: {
                    gsi1: {
                        partitionKey: "gsi1_pk",
                        sortKey: "gsi1_sk",
                    },
                    isLatestIdx: {
                        partitionKey: "pk",
                        sortKey: "isLatest",
                    },
                },
            }

排查关键点 #

• 检查GSI的最终一致性：DynamoDB全局二级索引默认是最终一致，更新数据后GSI同步可能存在延迟。如果延迟过后仍无法查询到数据，可排除此问题。
• 确认更新操作未误改关键字段：仔细核对更新请求，确保未意外修改gsi1_pk、isLatest或customerName字段，尤其是isLatest的类型是否保持为字符串"true"（DynamoDB是强类型，字符串与布尔值不匹配会被过滤）。
• 检查GSI的投影设置：你的GSI1未指定投影规则，默认仅投影索引键（gsi1_pk、gsi1_sk）。Query时FilterExpression依赖的customerName和isLatest需要回查主表，若主表与GSI数据不同步，会导致过滤后数据丢失。建议将这两个字段添加到GSI的投影中，避免回查主表。
• 验证数据类型一致性：确认被更新的数据项中，isLatest字段值为字符串"true"，而非布尔值true；customerName的大小写与Query中的":client"参数完全匹配（contains操作是大小写敏感的）。
• 检查Query分页：确认结果是否存在分页，查看返回结果中的LastEvaluatedKey，若存在则需继续查询后续页。

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