dynamodb golang query one Item

9404803

// +build example　　

　　
package main
　　

　　
import (
　　//    "flag"
　　"fmt"
　　"github.com/aws/aws-sdk-go/aws"
　　"github.com/aws/aws-sdk-go/aws/session"
　　"github.com/aws/aws-sdk-go/service/dynamodb"
　　"github.com/aws/aws-sdk-go/service/dynamodb/dynamodbattribute"
　　"os"
　　"time"
　　
)
　　

　　
func exitWithError(err error) {
　　fmt.Fprintln(os.Stderr, err)
　　os.Exit(1)
　　
}
　　

　　
func main() {
　　cfg := Config{}
　　if err := cfg.Load(); err != nil {
　　exitWithError(fmt.Errorf("failed to load config, %v", err))
　　}
　　

　　// Create the config specifiing the Region for the DynamoDB table.
　　// If Config.Region is not set the region must come from the shared
　　// config or AWS_REGION environment variable.
　　awscfg := &aws.Config{}
　　if len(cfg.Region) > 0 {
　　awscfg.WithRegion(cfg.Region)
　　}
　　

　　// Create the session that the DynamoDB service will use.
　　sess, err := session.NewSession(awscfg)
　　if err != nil {
　　exitWithError(fmt.Errorf("failed to create session, %v", err))
　　}
　　

　　// Create the DynamoDB service client to make the query request with.
　　svc := dynamodb.New(sess)
　　

　　// Build the query input parameters
　　params := &dynamodb.ScanInput{
　　TableName: aws.String(cfg.Table),
　　}
　　if cfg.Limit > 0 {
　　params.Limit = aws.Int64(cfg.Limit)
　　}
　　fmt.Println("params is: ", params)
　　// Make the DynamoDB Query API call
　　result, err := svc.Scan(params)
　　if err != nil {
　　exitWithError(fmt.Errorf("failed to make Query API call, %v", err))
　　}
　　

　　items := []Item{}
　　

　　// Unmarshal the Items field in the result value to the Item Go type.
　　err = dynamodbattribute.UnmarshalListOfMaps(result.Items, &items)
　　if err != nil {
　　exitWithError(fmt.Errorf("failed to unmarshal Query result items, %v", err))
　　}
　　

　　// Print out the items returned
　　for i, item := range items {
　　fmt.Printf("%d:  UserID: %d, Time: %s Msg: %s  Count: %d SecretKey:%s DeviceId: %s CampaginId:%s \n     ", i, item.UserID, item.Time, item.Msg, item.Count, item.SecretKey, item.DeviceId, item.CampaginId)
　　//fmt.Printf("\tNum Data Values: %d\n", len(item.Data))
　　
    }
　　

　　/*    //1231241  deviceid
　　params_del := &dynamodb.ScanInput{
　　TableName: aws.String(cfg.Table),
　　

　　}
　　*/
　　//query oneItem  demo
　　params_get := &dynamodb.GetItemInput{
　　Key: map[string]*dynamodb.AttributeValue{
　　"deviceid": {
　　S: aws.String("1231241"),
　　},
　　},
　　TableName: aws.String(cfg.Table), // Required
　　
    }
　　

　　resp, err_get := svc.GetItem(params_get)
　　oneItem := Item{}
　　if err_get == nil {
　　// resp is now filled
　　fmt.Printf("resp type is %T \n ", resp.Item)
　　err = dynamodbattribute.UnmarshalMap(resp.Item, &oneItem)
　　if err == nil {
　　fmt.Printf("  UserID: %d, Time: %s Msg: %s  Count: %d SecretKey:%s DeviceId: %s CampaginId:%s \n     ", oneItem.UserID, oneItem.Time, oneItem.Msg, oneItem.Count, oneItem.SecretKey, oneItem.DeviceId, oneItem.CampaginId)
　　} else {
　　fmt.Println(" Unmarshal err :", err)
　　}
　　//fmt.Println("convert to Struct obj  err is ", err, "oneItem is:", oneItem)
　　} else {
　　fmt.Println("GetItem err is: ", err_get)
　　}
　　

　　
}
　　

　　
type Item struct {
　　UserID     int       // Hash key, a.k.a. partition key
　　Time       time.Time // Range key, a.k.a. sort ke
　　Msg        string    `dynamo:"Message"`
　　Count      int       `dynamo:",omitempty"`
　　SecretKey  string    `dynamo:"-"` // Ignored
　　DeviceId   string    `dynamo:"deviceid"`
　　CampaginId string    `dynamo:"campid"`
　　
}
　　

　　
type Config struct {
　　Table  string // required
　　Region string // optional
　　Limit  int64  // optional
　　

　　
}
　　

　　
func (c *Config) Load() error {
　　//flag.Int64Var(&c.Limit, "limit", 0, "Limit is the max items to be returned, 0 is no limit")
　　//flag.StringVar(&c.Table, "table", "", "Table to Query on")
　　//flag.StringVar(&c.Region, "region", "", "AWS Region the table is in")
　　//flag.Parse()
　　c.Limit = 100
　　c.Region = "ap-southeast-1"
　　c.Table = "xxx_your_table_name"
　　if len(c.Table) == 0 {
　　//    flag.PrintDefaults()
　　return fmt.Errorf("table name is required.")
　　}
　　

　　return nil
　　
}