3

我想为 riak 实现一个 postcommit 钩子，它减少另一个桶中地图中的计数器。但是，我在处理 riak 数据类型时遇到了一些麻烦。

这是我尝试从riak console：

(riak@127.0.0.1)9>{ok, C} = riak:local_client().
{ok,{riak_client,['riak@127.0.0.1',undefined]}}
(riak@127.0.0.1)10>{ok, Obj} = C:get({<<"product">>, <<"default">>}, <<"1">>).
{ok,{r_object,{<<"product">>,<<"default">>},
          <<"1">>,
          [{r_content,{dict,5,16,16,8,80,48,
                            {[],[],[],[],[],[],[],[],[],[],[],[],...},
                            {{[],[],[],[],
                              [[<<"dot">>|{<<"#\tþù"...>>,{...}}]],
                              [],[],[],[],[],...}}},
                      <<69,2,0,0,0,11,114,105,97,107,95,100,116,95,109,97,112,
                        77,1,...>>}],
          [{<<35,9,254,249,108,41,151,242>>,{1,63593788980}}],
          {dict,1,16,16,8,80,48,
                {[],[],[],[],[],[],[],[],[],[],[],[],[],...},
                {{[],[],[],[],[],[],[],[],[],[],[],...}}},
          undefined}}
(riak@127.0.0.1)11> Mp = riak_object:get_value(O3).
<<69,2,0,0,0,11,114,105,97,107,95,100,116,95,109,97,112,
  77,1,131,80,0,0,0,206,120,1,203,96,...>>
(riak@127.0.0.1)12> MpP = riak_dt_map:from_binary(Mp).
{error,invalid_binary}

product存储桶数据类型设置为map. 存储的每个对象都应该有一个quantity我想减少的计数器。

但是，我在提交前或提交后的上下文中找不到任何处理数据类型的文档或示例代码。（实际上任何类型的例子都很少）。我一直在阅读riak_client和riak_dt_map的源代码，但我是 erlang 的新手，所以我进展缓慢，希望能得到一些帮助。

4

1 回答 1

2

您在那里的 r_object 不直接保存 riak_dt_map，而是保存包含 riak_dt_map 的 riak_kv_crdt，而 riak_dt_map 又包含您的计数器。

要更新计数器，您需要首先从地图中获取上下文：

{{Context,_},_}=riak_kv_crdt:value(Obj,riak_dt_map).

然后构建操作以递增 CRDT 中包含的映射中名为 <<"name">> 的计数器：

Op = {crdt_op,riak_dt_map,{update,[{update,{<<"name">>,riak_dt_emcntr},increment}]},Context}.

然后将该操作应用于 CRDT，提供要用于更新 vclock/版本向量的参与者 ID：

NewObj = riak_kv_crdt:update(Obj,Actor,Op).

结果应该是准备好被送回存储的另一个 r_object。

于 2015-03-17T14:47:17.457 回答