markuscraig / dynamodb-examples Goto Github PK

func main() {
	fmt.Println("running...")
	t := true
	// create an aws session
	sess := session.Must(session.NewSession(&aws.Config{
		CredentialsChainVerboseErrors: &t,
		Region:   aws.String("us-east-1"),
		Endpoint: aws.String("dynamodb-app:8000"),
		//EndPoint: aws.String("https://dynamodb.us-east-1.amazonaws.com"),
	}))
	fmt.Println("A")
	// create a dynamodb instance
	db := dynamodb.New(sess)

	// movie data
	movie := types.Movie{
		Year:  2015,
		Title: "The Big New Movie",
		Info: types.MovieInfo{
			Plot:   "Nothing happens at all.",
			Rating: 1.1,
		},
	}
	fmt.Println("B")
	// marshal the movie struct into an aws attribute value
	movieAVMap, err := dynamodbattribute.MarshalMap(movie)
	if err != nil {
		panic("Cannot marshal movie into AttributeValue map")
	}
	fmt.Println("C")
	// create the api params
	params := &dynamodb.PutItemInput{
		TableName: aws.String("Movies"),
		Item:      movieAVMap,
	}

	// put the item
	resp, err := db.PutItem(params)
	if err != nil {
		fmt.Printf("ERROR: %v\n", err.Error())
		return
	}

	// print the response data
	fmt.Println("Success")
	fmt.Println(resp)
}