Riak コトハジメ

更新:	2013-05-03
バージョン:	0.3.2
作者:	@voluntas

環境

OS:	CentOS 6.4 64bit
CPU:	2 コア
MEM:	2 GB

構成

3 ノード構成を作る準備

10.0.0.1
10.0.0.2
10.0.0.3

インストール

パッケージを持ってきてインストールするだけでおｋ

$ curl -O http://downloads.basho.com.s3-website-us-east-1.amazonaws.com/riak/CURRENT/rhel/6/riak-1.3.1-1.el6.x86_64.rpm
$ sudo rpm -Uvh riak-1.3.1-1.el6.x86_64.rpm

/etc/riak/vm.args 設定

ノードの IP を変更します。

127.0.0.1 を自分の IP に変更します:

## Name of the riak node
## -name [email protected]
-name [email protected]

/etc/riak/app.config 設定

127.0.0.1 を自分の IP に変更します:

%% {pb_ip,   "127.0.0.1" },
{pb_ip,   "10.0.0.1" },

%% {http, [ {"127.0.0.1", 8098 } ]},
{http, [ {"10.0.0.1", 8098 } ]},

2i 使いたいので LevelDB にします:

%% {storage_backend, riak_kv_bitcask_backend},
{storage_backend, riak_kv_eleveldb_backend},

起動

パッケージで入れると init.d に追加されてるのでさくっと上がります

起動:

$ sudo /etc/init.d/riak start

クラスター構築

メインを 10.0.0.1 とすると残りの 2 台から以下のコマンドを実行します

クラスターに追加:

$ riak-admin cluster join [email protected]
$ riak-admin cluster plan
$ riak-admin cluster commit

メンバーステータス:

[root@localhost ~]# riak-admin member-status
Attempting to restart script through sudo -H -u riak
================================= Membership ==================================
Status     Ring    Pending    Node
-------------------------------------------------------------------------------
valid      34.4%      --      '[email protected]'
valid      32.8%      --      '[email protected]'
valid      32.8%      --      '[email protected]'
-------------------------------------------------------------------------------
Valid:3 / Leaving:0 / Exiting:0 / Joining:0 / Down:0

REST

Python

インストール:

$ pip install riak

実行:

>>> import riak

>>> client = riak.RiakClient(port=8081, transport_class=riak.RiakPbcTransport)

>>> bucket = client.bucket('employee')

>>> obj = bucket.new('jeremy', 'engineer')

>>> obj.add_index('age_int', 23)
<riak.riak_object.RiakObject object at 0x108e64450>

>>> obj.add_index('state_bin', 'CA')
<riak.riak_object.RiakObject object at 0x108e64450>

>>> obj.store()
<riak.riak_object.RiakObject object at 0x108e64450>

>>> obj1 = bucket.new('helena', 'scientist')

>>> obj1.add_index('age_int', 32)
<riak.riak_object.RiakObject object at 0x108eca0d0>

>>> obj1.add_index('state_bin', 'CA')
<riak.riak_object.RiakObject object at 0x108eca0d0>

>>> obj1.store()
<riak.riak_object.RiakObject object at 0x108eca0d0>

>>> results = client.index('employee', 'age_int', 23).run()
>>> [ obj.get().get_key() for obj in results ]
['jeremy']

>>> results = client.index('employee', 'age_int', 23, 32).run()
>>> [ obj.get().get_key() for obj in results ]
['jeremy', 'helena']

>>> results = client.index('employee', 'state_bin', 'CA').run()
>>> [ obj.get().get_key() for obj in results ]
['helena', 'jeremy']

Erlang