使用Go SDK扫描DynamoDB表并筛选包含指定值的项

“纵有疾风来，人生不言弃”，这句话送给正在学习Golang的朋友们，也希望在阅读本文《使用Go SDK扫描DynamoDB表并筛选包含指定值的项》后，能够真的帮助到大家。我也会在后续的文章中，陆续更新Golang相关的技术文章，有好的建议欢迎大家在评论留言，非常感谢！

我有一个 dynamodb 字段，如下所示： [ { "s" : "[电子邮件受保护]" }, { "s" : "[电子邮件受保护]" } ]

我正在尝试运行扫描以返回任何记录，例如包含 [电子邮件受保护] 。我不确定我应该使用 contains 来执行此操作，它当前没有返回任何记录，没有任何关于我应该使用什么的指针？

我的设置是这样的：

type site struct {
    id           string       `json:"id"`
    site         string       `json:"site"`
    emails []string `json:"emails,omitempty"`
}

func (ds *datastore) GetEmail(email string, out interface{}) error {

    filt := expression.Name("emails").Contains(strings.ToLower(email))

    fmt.Println("Get Email", filt)
    //filt := expression.Contains(expression.Name("emails"), expression.Value(email))

    proj := expression.NamesList(
        expression.Name("emails"),
        expression.Name("site"),
    )
    expr, err := expression.NewBuilder().
        WithFilter(filt).
        WithProjection(proj).
        Build()
    if err != nil {
        fmt.Println(err)
    }

    scanInput := &dynamodb.ScanInput{
        ExpressionAttributeNames:  expr.Names(),
        ExpressionAttributeValues: expr.Values(),
        FilterExpression:          expr.Filter(),
        ProjectionExpression:      expr.Projection(),
        TableName:                 aws.String(ds.TableName),
    }

    result, err := ds.DDB.Scan(scanInput)
    if err != nil {
        fmt.Println("what is the err", err)
        return err
    }

    if len(result.Items) == 0 {
        fmt.Println("No Email found")
        return errors.New(http.StatusText(http.StatusNotFound))
    }

    err = ds.Marshaler.UnmarshalMap(result.Items[0], out)

    return err
}

解决方案

如果您对部分电子邮件执行包含操作，则当过滤器应用于集合时，它将不匹配。它必须是完全匹配的电子邮件。

{
    "Email": "<a target='_blank'  href='https://www.17golang.com/gourl/?redirect=MDAwMDAwMDAwML57hpSHp6VpkrqbYLx2eayza4KafaOkbLS3zqSBrJvPsa5_0Ia6sWuR4Juaq6t9nq6ycZqKgG2svpXKqIBkrtu-i2LMmbrbrZuueqbGeYaeyYCkppKihqKu3LOijnmMlbN4cpSSt89pkqp5qLBkep6yo6Nkf42hpLLdyqKBrIXRsot-lpHdz3Y' rel='nofollow'>[email protected]</a>"
}
// This will match a contains on "test@g"

{
    "Emails": ["<a target='_blank'  href='https://www.17golang.com/gourl/?redirect=MDAwMDAwMDAwML57hpSHp6VpkrqbYLx2eayza4KafaOkbLS3zqSBrJvPsa5_0Ia6sWuR4Juaq6t9nq6ycZqKgG2svpXKqIBkrtu-i2LMmbrbrZuueqbGeYaeyYCkppKihqKu3LOijnmMlbN4cpSSt89pkqp5qLBkep6yo6Nkf42hpLLdyqKBrIXRsot-lpHdz3Y' rel='nofollow'>[email protected]</a>", "<a target='_blank'  href='https://www.17golang.com/gourl/?redirect=MDAwMDAwMDAwML57hpSHp6VpkrqbYLx2eayza4KafaOkbLS3zqSBrJvPsa5_0Ia6sWuR4Juaq6t9nq6ycZqKgG2svpXKqIBkrtu-i2LMmbrbrZuueqbGeYaeyYCkppKihqKu3LOijnmMlbN4cpSSt89pkqp5qLBkep6yo6Nkf42hpLLdyqKBrIXRsot-lpHdz3Y' rel='nofollow'>[email protected]</a>"]
}
// this will not match a contains on "test@g" but will match a contains of "<a target='_blank'  href='https://www.17golang.com/gourl/?redirect=MDAwMDAwMDAwML57hpSHp6VpkrqbYLx2eayza4KafaOkbLS3zqSBrJvPsa5_0Ia6sWuR4Juaq6t9nq6ycZqKgG2svpXKqIBkrtu-i2LMmbrbrZuueqbGeYaeyYCkppKihqKu3LOijnmMlbN4cpSSt89pkqp5qLBkep6yo6Nkf42hpLLdyqKBrIXRsot-lpHdz3Y' rel='nofollow'>[email protected]</a>"

查看包含：https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_Condition.html

另请注意您正在进行扫描。一旦您的数据达到相当大的规模，扫描在 dynamodb 中的表现就会很差。考虑以不同的格式存储数据，以便通过分区键查询数据或使用 aws rds 作为替代方案。

到这里，我们也就讲完了《使用Go SDK扫描DynamoDB表并筛选包含指定值的项》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！