如何通过LSI/GSI实现DynamoDB会话按lastMessageDate动态排序？

核心结论：用GSI（全局二级索引）完全可以实现你的需求，LSI不适用 #

为什么LSI不行？ #

LSI（本地二级索引）的分区键必须和主表分区键一致，且排序键是创建表时就固定的属性。你的主表分区键是conversationID，若用LSI，只能基于主表某个固定字段做排序，但你需要的是动态更新排序字段（每次新消息都要修改lastMessageDate），而LSI无法支持这种场景——主表的主键（PK+SK）不可修改，LSI排序键绑定主表属性后，没法通过更新主表字段调整排序逻辑。

用GSI的具体实现步骤 #

1. 定义GSI结构 #

给主表创建一个GSI，配置如下：

• GSI分区键（PK）：设为聚合用户会话的固定前缀+用户ID，比如USER_CONVERSATIONS#<your-user-id>。这样同一个用户的所有会话会被聚合到GSI的同一个分区，方便批量查询。

• GSI排序键（SK）：直接使用lastMessageDate字段。为让最新会话排在最顶端，建议用倒序时间格式：

  • 方案A：存储Unix毫秒时间戳的负数（比如-1716184496000），DynamoDB默认正序查询时，数值大的（时间更近的）会排在前面。
  • 方案B：存储ISO8601格式的时间字符串（比如2024-05-20T12:34:56Z），查询时指定scanIndexForward: false实现倒序。

  额外优化：若担心多个会话同一毫秒更新导致SK冲突，可把conversationID拼到SK后面，比如#<lastMessageDate>#<conversationID>，既保证唯一性，又不影响时间排序逻辑。

2. 数据更新逻辑 #

每次会话产生新消息时，直接更新主表中该会话的lastMessageDate字段即可——DynamoDB会自动同步更新GSI对应的条目，无需额外操作GSI。

3. AppSync GraphQL查询配置 #

在GraphQL schema中定义查询，指定使用这个GSI：

type Query {
  getUserConversations(userId: String!): [Conversation]
    @aws_query(
      table: "YourConversationTable"
      index: "UserConversationsByLastMessageDateIndex" // 你的GSI名称
      query: {
        keyCondition: {
          pk: { eq: "USER_CONVERSATIONS#${ctx.args.userId}" }
        }
        scanIndexForward: false // 用ISO8601字符串时需要开启倒序；用负数时间戳则无需设置
      }
    )
}

注意事项 #

• 一致性选择：GSI默认是最终一致性，若需要实时获取最新会话排序，可在查询时加上consistentRead: true，但会增加成本和延迟，需根据业务场景权衡。
• 索引开销：GSI会占用额外存储和写入吞吐量，每次更新lastMessageDate都会触发GSI写入操作，需评估业务量是否在预算范围内。

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