18
18

Delete article

Deleted articles cannot be recovered.

Draft of this article would be also deleted.

Are you sure you want to delete this article?

More than 5 years have passed since last update.

DynamoDBのドキュメントAPI、JSON対応したから簡単なサンプルで紹介する part1

Posted at

DynamoDBはAWSが提供するNoSQLサービスで、スケールして運用管理いらず、簡単に使える所がメリットです。DynamoDBは最近立て続けにアップデートしており、特に最近JSONが保存できるようになって使いやすくなった事もあるので、記念(?)と自分のおさらいもかねて、さっくりとサンプルを何回かにわけてご紹介していこうと思っています。長くなってきたら分割するくらいの感じで。

環境

JDK 1.7.0_71
Eclipse Kepler
AWS Eclipse Plugin
AWS SDK for Java 1.9.1

他の言語でも同様のことが出来るはずですが、まあひとまずJavaで。本来はGoで書きたいところですが、まあそれはおいおい。

テーブルを作成する

こんな感じのコードスニペットになります。DynamoDBの最近のJava SDKだと、Tableを中心に操作する感じになります。前よりは直感的になったように思います。超シンプルなGameのイベントアクティビティを管理するテーブルを作成してみます。

    String tablename = "Game";
    Table table = dynamo.createTable(tablename, 
                Arrays.asList(
                    new KeySchemaElement("gameId", KeyType.HASH),
                    new KeySchemaElement("time", KeyType.RANGE)), 
                Arrays.asList(
                    new AttributeDefinition("gameId", ScalarAttributeType.N), 
                    new AttributeDefinition("time", ScalarAttributeType.S)),
                new ProvisionedThroughput(5L, 5L)
            );


テーブルを取る

こんだけ。

    DynamoDB dynamo = new DynamoDB(client);
    Table table = dynamo.getTable("Game");

データのPUT

次はデータ入れてみます。
Tableに入れるデータ構造としてはItemを作ります。Itemが各レコードと思ってもらって差し支えなさそう。
最近のアップデートで、JSON、Map、Listなどを入れられるようになりました。

    //JSONつくるのめんどいので、Jacksonで適当なクラスからさくっと生成
    Meta alias = new Meta();
    {
        alias.gameName = "shot6";
        alias.ranking = 5;
        alias.gameStatus = "COMPLETE";
    }
    ObjectMapper mapper = new ObjectMapper();
    String json = mapper.writeValueAsString(alias);

    table.putItem(new Item()
            .withPrimaryKey("gameId", 111, "time", "201410210214")
            .withString("playerId", "hoge1")
            .withInt("score", 10012)
            .withList("teamFriendId", "foo1", "foo2", "foo3")
            .withMap("additionalInfo", ImmutableMap.of("aaa1", "bbb1", "aaa2", "bbb2"))
            .withJSON("metadata", json));

ま、それ以外にもバルクでちょっとロードしておきます。まあこの辺はみなさん適当にやってみてくださし。

GETしてみる

データ入れたので今度はGETしてみます。Hash + Rangeでデータ取ってきます。

        Item item = table.getItem("gameId", 111, "time", "201410210214");
        //AttributeをMap<String, Object>でまわせるのは便利
        for (Map.Entry<String, Object> attribute : item.attributes()) {
            System.out
                    .println(attribute.getKey() + ", " + attribute.getValue());
        }

        //mapでとると、DynamoDB側ではNumberがBigDecimalにマップされてて若干はまった・・・
        Map<String, Object> map = item.asMap();
        BigDecimal score = (BigDecimal) map.get("score");
        System.out.println("score from map : " + score);

        //Itemから取ると、コンバートしてくれている
        int scoreResult = item.getInt("score");
        System.out.println("score from Item : " + scoreResult);

        //JSONも取れる
        String metadata = item.getJSON("metadata");
        System.out.println(metadata);

        //JSONから子供の部分だけ、Itemにして扱える
        Item partItem = Item.fromJSON(metadata);
        System.out.println(partItem.get("gameName") + ", "
                + partItem.get("ranking") + "," + partItem.get("gameStatus"));

最後の部分だけ、少しだけ捕捉すると、全体のJSONがこんな感じだとすると、

{
  "teamFriendId" : [ "foo1", "foo2", "foo3" ],
  "time" : "201410210214",
  "playerId" : "hoge1",
  "gameId" : 111,
  "score" : 10012,
  "additionalInfo" : {
    "aaa1" : "bbb1",
    "aaa2" : "bbb2"
  },
  "metadata" : {
    "gameName" : "shot6",
    "gameStatus" : "COMPLETE",
    "ranking" : 5
  }
}

こんな感じで部分的に取れます。

{
  "gameName" : "shot6",
  "gameStatus" : "COMPLETE",
  "ranking" : 5
}

まとめ

今回はこれくらいにしておきますかねー。次回はもう少しQueryあたりをやろうかなと思います。

18
18
0

Register as a new user and use Qiita more conveniently

  1. You get articles that match your needs
  2. You can efficiently read back useful information
  3. You can use dark theme
What you can do with signing up
18
18

Delete article

Deleted articles cannot be recovered.

Draft of this article would be also deleted.

Are you sure you want to delete this article?