DynamoDBlocalでDynamoDBをひとまず触れるようにする

概要

DynamoDBはAWSのマネージドサービスの一つです。
DynamoDBは、開発のために手元のPCで動作させることができます。
本記事では、以下の方法をご紹介します。

• DynamoDBLocalを手元のPCに入れる
• aws-cliでDynamoDBを操作する
• Go言語でDynamoDBを操作する

DynamoDBLocalを手元のPCに入れる

以下のURLから、DynamoDBLocalをダウンロードします。
https://docs.aws.amazon.com/ja_jp/amazondynamodb/latest/developerguide/DynamoDBLocal.html

アーカイブを解凍したら、以下のコマンドでDynamoDBローカルを立ち上げます。

$ java -Djava.library.path=./DynamoDBLocal_lib -jar DynamoDBLocal.jar -sharedDb

http://localhost:8000/shell/にアクセスするとJavascriptで操作することもできます。

aws-cliで操作する

aws-cliで操作するときのポイントは、以下のとおりです。

• --endpoint-url に http://localhost:8000を指定する
• ローカルでも--profileまたはAWS_PROFILEの設定が必要となる

テーブルを作成する

$ aws dynamodb create-table --table-name Persons \
   --attribute-definitions AttributeName=Id,AttributeType=N \
  --key-schema AttributeName=Id,KeyType=HASH \
  --provisioned-throughput ReadCapacityUnits=1,WriteCapacityUnits=1 \
  --endpoint-url http://localhost:8000

テーブル一覧を表示する

$ aws dynamodb list-tables --endpoint-url http://localhost:8000

テーブルにデータを挿入する

$ aws dynamodb put-item --table-name Persons --item '{"Id":{"N":"1"},"Name":{"S":"Jack"}}' --endpoint-url http://localhost:8000

データを取得する

$ aws dynamodb get-item --table-name Persons --key '{"Id":{"N":"1"}}' --endpoint-url http://localhost:8000

データをスキャンする

$ aws dynamodb scan --table-name Persons --endpoint-url http://localhost:8000

Go言語で操作する

ダミーのCredentialsを用意しておく

ローカルなDynamoDBに接続する際もCredentialを設定する必要があるので、以下のようにダミーを設定しておきます。

# ~/.aws/credentials
[dummy]
aws_access_key_id = dummy
aws_secret_access_key = dummy

SDKの導入

go get -u github.com/aws/aws-sdk-go

ひとまず参照するコード

aws-cliで作成したPersonsテーブルからデータを取得するコードです。

// main.go
package main

import (
    "github.com/aws/aws-sdk-go/aws/session"
    "github.com/aws/aws-sdk-go/aws"
    "github.com/aws/aws-sdk-go/service/dynamodb"
    "fmt"
    "github.com/aws/aws-sdk-go/aws/credentials"
)

func main() {
    dynamoSession, err := session.NewSession(&aws.Config{
        Region: aws.String("ap-northeast-1"),
        Endpoint: aws.String("http://localhost:8000"),
        Credentials: credentials.NewStaticCredentials("dummy", "dummy", "dummy"),
    })
    if err != nil {
        panic(err)
    }

    db := dynamodb.New(dynamoSession)

    res, err := db.GetItem(&dynamodb.GetItemInput{
        TableName: aws.String("Persons"),
        Key: map[string]*dynamodb.AttributeValue{
            "Id": {
                N: aws.String("1"),
            },
        },
        AttributesToGet: []*string{
            aws.String("Name"),
        },
        ConsistentRead: aws.Bool(true),
        ReturnConsumedCapacity: aws.String("NONE"),
    })

    if err != nil {
        panic(err)
    }

    fmt.Println(*res.Item["Name"])
}

guregu/dynamoを使用する

ORMのようなものです。
jsonモジュールのように、構造体にマッピングしてくれます。

$ go get github.com/guregu/dynamo

// main.go
package main

import (
    "github.com/aws/aws-sdk-go/aws/session"
    "github.com/aws/aws-sdk-go/aws"
    "github.com/aws/aws-sdk-go/aws/credentials"
    "github.com/guregu/dynamo"
)

type Person struct {
    ID int `dynamo:"Id"`
    Name string `dynamo:"Name"`
}

func main() {
    dynamoSession, err := session.NewSession(&aws.Config{
        Region: aws.String("ap-northeast-1"),
        Endpoint: aws.String("http://localhost:8000"),
        Credentials: credentials.NewStaticCredentials("dummy", "dummy", "dummy"),
    })
    if err != nil {
        panic(err)
    }

    db := dynamo.New(dynamoSession)
    table := db.Table("Persons")

    var ret Person
    err = table.Get("Id", 1).One(&ret)
    if err != nil {
        panic(err)
    }

    println(ret.Name)
}