使用golang检索dynamodb中的最新记录

一分耕耘，一分收获！既然打开了这篇文章《使用golang检索dynamodb中的最新记录》，就坚持看下去吧！文中内容包含等等知识点...希望你能在阅读本文后，能真真实实学到知识或者帮你解决心中的疑惑，也欢迎大佬或者新人朋友们多留言评论，多给建议！谢谢！

我正在尝试检索插入到 dynamodb 表中的最新记录，表结构如下：

• 日期（订单号）
• id（分区键）
• 价值

日期值是unix时间戳，这是一个示例JSON数据：

{
  "date": 1590312898,
  "id": "87a6614b-1d05-44af-ab4b-6bc0957796b3",
  "value": 36
}

我尝试使用 scaninput 函数将 limit 结果设置为 1，但我无法获得正确的顺序，因此我得到了错误的行。我尝试使用以下代码：

filt := expression.name("date").notequal(expression.value(nil))

    proj := expression.nameslist(expression.name("date"), expression.name("id"), expression.name("value"))

    expr, err := expression.newbuilder().withfilter(filt).withprojection(proj).build()

    if err != nil {
        fmt.println("Got error building expression:")
        fmt.println(err.error())
    }

    // build the query input parameters
    params := &dynamodb.scaninput{
        limit:                     aws.int64(1),
        expressionattributenames:  expr.names(),
        expressionattributevalues: expr.values(),
        filterexpression:          expr.filter(),
        projectionexpression:      expr.projection(),
        tablename:                 aws.string(tablename),
    }

    // make the dynamodb query api call
    result, err := svc.scan(params)

也许我必须使用 scanindexforward 参数，但我不明白如何以正确的方式设置它。

有什么建议吗？这是正确的方法吗？

提前致谢

解决方案更新：

我必须使用 queryinput 而不是 scaninput 函数才能使用 scaninputforward，这是新代码：

var queryInput = &dynamodb.QueryInput{
            TableName: aws.String(tableName),
            KeyConditions: map[string]*dynamodb.Condition{
                "Type": {
                    ComparisonOperator: aws.String("EQ"),
                    AttributeValueList: []*dynamodb.AttributeValue{
                        {
                            S: aws.String("SM"),
                        },
                    },
                },
            },
            ScanIndexForward: aws.Bool(false),
            Limit:            aws.Int64(1),
        }

        result, err := svc.Query(queryInput)

解决方案

首先，由于您的日期是分区键，因此每当您在后端进行扫描时，DynamoDB 都会单独调用每个分区。无论返回的顺序如何，都将是响应中的顺序。

如果您想使用 ScanIndexForward 检索此内容，那么您将查看排序（或范围键）

指定索引遍历的顺序：如果为true（默认），则按升序进行遍历；如果为 false，则按降序进行遍历。

具有相同分区键值的项目按排序键按排序顺序存储。如果排序键数据类型为 Number，则结果按数字顺序存储。对于 String 类型，结果按 UTF-8 字节顺序存储。对于 Binary 类型，DynamoDB 将二进制数据的每个字节视为无符号。

我建议您了解如何重新构建 DynamoDB 表以使用 Global Secondary Index，该表将使用所有项目都使用的分区键以及日期的排序键。然后，您可以使用 ScanIndexForward 查询并检索最大值。

否则您将不得不执行扫描，然后按订单进行后处理。

理论要掌握，实操不能落！以上关于《使用golang检索dynamodb中的最新记录》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注编程网公众号吧！