扫描 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 作为替代方案。
我有一个 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 作为替代方案。