在提交后挂钩中处理风险数据类型

Question

我想为 riak 实现一个 post 提交挂钩，它会减少另一个存储桶中映射中的计数器。但是我在处理 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 的计数器，我想将其递减。

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

Answer 1

您那里的 r_object 并不直接包含 riak_dt_map，而是包含 riak_kv_crdt，后者包含 riak_dt_map，而 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/version 向量的参与者 ID：

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

结果应该是另一个 r_object，可以送回存储。

在提交后挂钩中处理风险数据类型

dealing with riak datatypes in postcommit hooks

erlang

riak

post-commit-hook

crdt