扫描 dynamodb table 并使用 go sdk 列表中的包含

Scan a dynamodb table and using contains on a list with go sdk

我有一个 dynamodb 字段,如下所示: [ { "S" : "test@gmail.com" }, { "S" : "test2@gmail.com" } ]

我正在尝试 运行 扫描到 return 任何记录,例如包含 test@gmail.com 。我不确定我是否应该使用 contains 来执行此操作,它目前没有 returning 任何记录,关于我应该使用什么的任何指示?

我的设置是这样的:

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": "test@gmail.com"
}
// This will match a contains on "test@g"

{
    "Emails": ["test@gmail.com", "another@gmail.com"]
}
// this will not match a contains on "test@g" but will match a contains of "test@gmail.com"

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

另请注意,您正在进行扫描。一旦您的数据非常大,扫描在 Dynamodb 中的表现就会很差。考虑以不同的格式存储数据,以便通过分区键查询数据或使用 AWS RDS 作为替代方案。