Ruby 製サーバーレスフレームワーク Jets から DynamoDB アイテムの CRUD 操作を試す

Ruby 製サーバーレスフレームワーク Jets から DynamoDB アイテムの CRUD 操作を試す:

はじめに

Ruby でサーバーレスアプリケーションを実装できるフレームワーク、 Jets。Rails ライクに使える、サーバーレスアプリケーションに入門しやすそうなフレームワークです。

日本国内の情報はまだまだ少ないですが、個人的にはかなりアツいフレームワークだと考えています。 先日以下のような検証記事を書きました。これからもっと検証を進めていく予定です。

Ruby 製サーバーレスフレームワークの Jets を検証してみたら、Rails ライクに使えていい感じだった

そんな Jets ですが、データベースを MySQL や PostgreSQL といった RDB だけではなく、Key-Value-Store である DynamoDB も使えるようです。

この記事では、Jets のドキュメントに則って、DynamoDB をデータベースとして使う場合について検証してみました。

検証環境情報

Mac OS X 10.13.6
HomeBrew 1.8.6
ruby 2.5.1
Jets 1.4.5
nodejs v9.11.2
Java version 100

検証の概要

以下について検証します。

ローカル環境において、DynamoDB を設定し、Jets アプリケーションの console から DynamoDB テーブルに CRUD 操作する

検証手順

Jets アプリケーション新規作成

まず、サンプルとなる Jets アプリケーションを新規作成します。

jets new jets-dynamodb-sandbox 
cd jets-dynamodb-sandbox

dynamodb-local インストール・起動確認

次に、ローカル環境で DynamoDB を使えるよう、dynamodb-local をインストールします。

brew cask install dynamodb-local

インストールできたら、dynamodb-local を起動しましょう。成功すると、8000 番ポートで起動していることが確認できます。

dynamodb-local 
 
Initializing DynamoDB Local with the following configuration: 
Port:  8000 
InMemory:  false 
DbPath:  null 
SharedDb:  false 
shouldDelayTransientStatuses:  false 
CorsParams:  *

dynamodb-admin インストール・起動確認

dynamodb-local で作成したテーブルの内容を確認しやすくするため、dynamodb-local 用の GUI ツール、dynamodb-admin をインストールします。

npm install dynamodb-admin -g

dynamodb-admin のエンドポイントを環境変数で設定し、dynamodb-admin を起動します。

export DYNAMO_ENDPOINT=http://localhost:8000 
dynamodb-admin 
 
dynamodb-admin listening on http://localhost:8001 (alternatively http://0.0.0.0:8001)

http://localhost:8001 にアクセスすると、dynamodb-admin の画面が表示されます。

Jets アプリケーション DynamoDB 接続設定確認

dynamodb-local の設定ができたら、Jets アプリケーションにおける DynamoDB 接続設定を確認します。

config/dynamodb.yml をエディタで開きます。

config/dynamodb.yml

development: 
  table_namespace: <%= Jets.config.table_namespace %> 
  # More examples: 
  # table_namespace: demo-dev 
 
  endpoint: http://localhost:8000  
  # comment out if want to test with real dynamodb 
  # on AWS. You can also set the DYNAMODB_ENDPOINT environment variable. 
  # You can also are actually deploying a development environment is to 
  # change bin/server and export DYNAMODB_ENDPOINT=http://localhost:8000 at the top 
  # there.

development 以下の endpoint が http://localhost:8000 となっています。

今回はdynamodb-local をポート番号を変更せず、デフォルトのまま利用しているので、特に変更は不要です。

もしdynamodb-local のポート番号を変更して起動している場合は、変更したポート番号に修正してください。

DynamoDB テーブルマイグレーションファイル作成

それでは Jets アプリケーション用に、DynamoDB テーブルのマイグレーションファイルを作成しましょう。

今回は posts というテーブルを作成します。

以下コマンドでマイグレーションファイルを作成します。

jets dynamodb:generate create_posts 
 
Migration file created: ./dynamodb/migrate/20190105131708-create_posts_migration.rb. 
 
To run: 
  jets dynamodb:migrate ./dynamodb/migrate/20190105131708-create_posts_migration.rb

作成されたマイグレーションファイルは以下の通りです。ActiveRecord のマイグレーションファイルと似ていますね。

dynamodb/migrate/20190105131708-create_posts_migration.rb

class CreatePostsMigration < Dynomite::Migration 
  def up 
    create_table :posts do |t| 
      t.partition_key "id:string:hash" # required 
      t.provisioned_throughput(5) # sets both read and write, defaults to 5 when not set 
 
      # Instead of using partition_key and sort_key you can set the 
      # key schema directly also 
      # t.key_schema([ 
      #     {attribute_name: "id", :key_type=>"HASH"}, 
      #     {attribute_name: "created_at", :key_type=>"RANGE"} 
      #   ]) 
      # t.attribute_definitions([ 
      #   {attribute_name: "id", attribute_type: "N"}, 
      #   {attribute_name: "created_at", attribute_type: "S"} 
      # ]) 
 
      # other ways to set provisioned_throughput 
      # t.provisioned_throughput(:read, 10) 
      # t.provisioned_throughput(:write, 10) 
      # t.provisioned_throughput( 
      #   read_capacity_units: 5, 
      #   write_capacity_units: 5 
      # ) 
    end 
  end 
end

マイグレーション実行

紹介されているコマンドをそのまま使い、マイグレーションを実行しましょう。

jets dynamodb:migrate ./dynamodb/migrate/20190105131708-create_posts_migration.rb 
 
Running database migrations 
DynamoDB Table: posts Status: ACTIVE

実行後、dynamodb-admin をリフレッシュしてみると、テーブルが作成されているのが確認できます。

Post モデル作成

DynamoDB のテーブル、 posts に対応した Post モデルを作成します。

Post モデルの継承元クラスですが、今回は ApplicationRecord ではなく、　Dynomite::Item として作成します。

Dynomite は、ActiveRecord ライクに DynamoDB を操作できるラッパーとなる gem です。

Dynomite は、Jets と同じ作者 tongueroo さんが開発しています。

app/models/post.rb

class Post < Dynomite::Item 
end

DynamoDB テーブルへの CRUD 操作確認

ここまでで、最低限の設定は完了しました。

いよいよ Jets アプリケーション上で、DynamoDB テーブルにアイテムが作成できるか確認します。

Jets アプリケーションのコンソールを開きます。

jets console

Create

Jets アプリケーションのコンソール上で、Post モデルのアイテムを作成してみます。

post = Post.new(id: "myid", title: "my title") 
post.replace 
 
{"id"=>"b83c4d4b6fd7af91a7f44bc8df7d17d2ac63a76a", :id=>"myid", :title=>"my title", "created\_at"=>"2019-01-05T04:32:15Z", "updated\_at"=>"2019-01-05T04:32:15Z"}

コマンド実行後、再度 dynamodb-admin の画面をリフレッシュして確認すると、テーブルにアイテムが作成されているのが確認できます。

Read

作成したアイテムは、find メソッドで検索できます。

post_found = Post.find('myid') 
 
<Post:0x00007fc07120ec00 @attrs={"created_at"=>"2019-01-05T09:40:27Z", "id"=>"myid", "title"=>"hoge", "updated_at"=>019-01-05T09:40:27Z"}>

Update

作成したアイテムにおいて、アイテムの内容全体を更新する場合は、作成時と同様 replace メソッドを使います。

post = Post.new(id: 'myid', title: 'title updated') 
post.replace 
 
{"id"=>"90f716a63f24c3099135c202184ec8b37f25e737", :id=>"myid", :title=>"title updated", "created_at"=>"2019-01-05T10:10:40Z", "updated_at"=>"2019-01-05T10:10:40Z"}

作成したアイテムに新たな属性を追加したい場合は、attrs メソッドで新たな属性を追加し、replace メソッドを実行します。

post_updated = Post.find('myid') 
post_updated.attrs(content: 'hogehoge') 
post.replace 
 
{"id"=>"90f716a63f24c3099135c202184ec8b37f25e737", :id=>"myid", :title=>"title updated", "created_at"=>"2019-01-05T10:10:40Z", "updated_at"=>"2019-01-05T10:10:40Z", "content"=>"hogehoge"}

Delete

アイテムを削除する場合は、delete メソッドを実行します。

post_deleted = Post.delete('myid') 
 
# <struct Aws::DynamoDB::Types::DeleteItemOutput attributes=nil, consumed_capacity=nil, item_collection_metrics=nil>

こちらで検証は以上です！

おわりに

今まで DynamoDB といった KVS なデータストレージに触れる機会はあまりなかったのですが、Jets を使うと実際に動かしながら試すことができて良さそうだなと思いました。

DynamoDB への操作もまだまだ基本的な操作のみしかしていないので、動かしながら基本的な概念も確認していきたいと考えています。

また別途、Jets アプリケーションの画面から、DynamoDB テーブルへの操作も試してみたいと思います。

このブログを検索

IT音痴アラフィフおやじのストック記事倉庫