文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

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

2024-04-04 23:51

关注

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

问题内容

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

日期值是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中的最新记录》的详细介绍,大家都掌握了吧!如果想要继续提升自己的能力,那么就来关注编程网公众号吧!

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯