json - 如何在 GO 的 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

在这种情况下，您应该使用类型断言。

试试这个：

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

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

Answer 3

要将 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)
}