删除没有主要索引DynamoDB的数据

Question

目前，我正在使用DynamoDB来存储AWS WebSockets的连接ID，并且我将它们用作文档的主要索引，总的来说，我的模式看起来像这样的

{
      ID: connectionId,
      userId: userId,
      domainName,
      stage,
}

架构都可以使用，只是一个问题，我有一个SNS主题可以调度用户ID对此API端点，我需要删除与该用户ID的所有连接，我正在研究batchWrite，但是它要求我将用户ID用作主索引而不是ConnectionID，我选择了该模式类型，因为它是灵活的，我可以轻松找到它用户断开连接并使用一个命令删除连接ID的文档，并且还添加它，我是否可以选择无主键批量批量表？第二种选择是改变架构，因为

{  
      ID: userId,
      connections: [
          {
              connectionId: connectionId,
              stage,
              domainName
          }
      ],
}

我不太喜欢的，这是唯一的其他选择吗？

Answer 1

您需要按以下方式更改DB模式：

对于主要索引，

connectionId: partition key

创建全局辅助索引：

userId: partition key

第一个方案：

当您需要删除属于用户ID的所有连接时，您需要使用UserID查询，然后运行batchwrite命令使用GSI删除所有行

查询：

const items = ddb.query({
    TableName: "connections",
    IndexName: "globalSecondaryIndexNameHere",
    KeyConditionExpression: "userId = :userId",
    ExpressionAttributeValues: {
        ":userId": "abc"
    }
})

然后循环投掷项目并提出批处理请求以删除：

ddb.batchWrite({
    RequestItems: {
        "connections": [
            {
                DeleteRequest: {
                    Key: {
                        "connectionId": "connectionId1"
                    }
                }
            },
            {
                DeleteRequest: {
                    Key: {
                        "connectionId": "connectionId2"
                    }
                }
            },
            // ...
        ]
    }
})

第二个方案：

当您需要通过ConnectionID delete

delete delete：

ddb.deleteItem({
    TableName: "connections",
    Key: {
        "connectionId": "connectionId1"
    }
})

Note：我建议使用 “ https://aws.amazon.com/appsync/” rel =“ nofollow noreferrer”> aws appsync 而不是API网关，因为AppSync管理您的ConnectionID，而不是在Dynampyodb中保存它们，加上许多其他原因在这里