如何在dynamodb中保存JSON响应

Question

我想在aws-dynamodb中保存一个JSON响应，我正在使用aws-dynamodb-sdk。我目前正在做的是：

func (e *DB) saveToDynamodb(data map[string]interface{}){
params := &dynamodb.PutItemInput{
    Item: map[string]*dynamodb.AttributeValue{
        "Key": {
            M: data,
        },
    },
    TableName: aws.String("Asset_Data"),
}
resp, err := e.dynamodb.PutItem(params)

if err != nil {
    fmt.Println(err.Error())
    return
}
fmt.Println(resp)
}

但是正如您所看到的，数据是map [string] interface {}类型的，而期望的类型是map [string] * AttributeValue，这就是为什么会出现编译错误的原因。

有保存JSON响应的解决方法吗？

Answer 1

将json放入DynamoDB的最佳方法是使用辅助函数。

func ExampleMarshal() (map[string]*dynamodb.AttributeValue, error) {                                                                                                    
  type Record struct {                                                                                                     
    Bytes   []byte                                                                                                         
    MyField string                                                                                                         
    Letters []string                                                                                                       
    Numbers []int                                                                                                          
  }                                                                                                                        

  r := Record{                                                                                                             
    Bytes:   []byte{48, 49},                                                                                               
    MyField: "MyFieldValue",                                                                                               
    Letters: []string{"a", "b", "c", "d"},                                                                                 
    Numbers: []int{1, 2, 3},                                                                                               
  }                                                                                                                        
  av, err := dynamodbattribute.Marshal(r)
  return map[string]*dynamodb.AttributeValue{"object":av}, err
}

Answer 2

要将 JSON 放入 aws-dynamodb 中，我们首先需要迭代 JSON 结构的每个属性，然后按以下方式将其转换为 dynamodb.AttributeValue：

func (e *DB) saveToDynamodb(data map[string]interface{}){
var vv=make(map[string]*dynamodb.AttributeValue)

for k,v:=range data{
    x:=(v.(string)) //assert string type
    xx:=&(x)
    vv[k]=&dynamodb.AttributeValue{S: xx,}
}
//s:=data["asset_id"].(string)
params := &dynamodb.PutItemInput{
    Item: vv,
    TableName: aws.String("Asset_Data"), // Required
}
resp, err := e.dynamodb.PutItem(params)

if err != nil {
    // Print the error, cast err to awserr.Error to get the Code and
    // Message from an error.
    fmt.Println(err.Error())
    return
}

// Pretty-print the response data.
fmt.Println(resp)
}