Erlang MapReduce в базе данных Riak дает исключение

Question

Я прохожу учебники по riak и Erlang, я сохранил данные в riak с помощью riak-erlang-client, и я сделал следующее:

1> {ok,Pid} = riakc_pb_socket:start_link("127.0.0.1", 8087).
{ok,<0.34.0>} 
2> Val1 = [1,2,3]. 
[1,2,3]
3> MyBucket = <<"numbers">>.
<<"numbers">>
4> Obj1 = riakc_obj:new(MyBucket,<<"ott">>,Val1).
5> riakc_pb_socket:put(Pid,Obj1).
ok
6> {ok, Fetched} = riakc_pb_socket:get(Pid,MyBucket,<<"ott">>).
{ok,{riakc_obj,<<"numbers">>,<<"ott">>,
           <<107,206,97,96,96,96,204,96,202,5,82,28,202,156,255,126,
             6,251,159,184,148,193,148,...>>,
           [{{dict,3,16,16,8,80,48,
                   {[],[],[],[],[],[],[],[],[],[],[],[],...},
                   {{[],[],[],[],[],[],[],[],[],[],...}}},
             <<131,107,0,3,1,2,3>>}],
           undefined,undefined}}
7> Val1 == binary_to_term(riakc_obj:get_value(Fetched)).
true
8> binary_to_term(riakc_obj:get_value(Fetched)).        
[1,2,3]

Теперь все было хорошо, я хочу извлечь значения из списка [1,2,3], которые делятся только на 2 из mapreduce через erlang.

для этого я сделал следующее,

9>Res = fun(Fetched,none)-> [X || X <- binary_to_term(riakc_obj:get_value(Fetched)), X rem 2 == 0] end.

Я не знаю точно, что следует писать в параметрах функции, так как я новичок в erlang и riak, поэтому, пожалуйста, исправьте меня, если я не прав.

Теперь, когда я иду на mapreduce, я написал это,

10>{ok , [{X}]} = riakc_pb_socket:mapred(Pid,[{<<"numbers">>,<<"ott">>}],[{map,{qfun,Res},none,true}]).

Было выброшено следующее исключение. Пожалуйста, предложите мне хороший способ понять, что происходит и как запустить mapreduce.

** exception exit: {noproc,{gen_server,call,
                                   [<0.34.0>,
                                    {req,{rpbmapredreq,<<131,108,0,0,0,3,104,2,100,0,6,105,
                                                         110,112,117,116,115,108,...>>,
                                                       <<"application/x-erlang-binary">>},
                                         60100,
                                         {132578423,<0.49.0>}},
                                    infinity]}}
 in function  gen_server:call/3 (gen_server.erl, line 188)
 in call from riakc_pb_socket:mapred/5 (src/riakc_pb_socket.erl, line 643)

Пожалуйста, помогите мне и предложите мне, я следовал по ссылкам, но я не понимаю, как писать самостоятельно для maprecece, поэтому, пожалуйста, помогите мне... это поможет мне.

Answer 1

Вы получаете ошибку noproc, потому что передаете функцию arity-2. Фазовая функция карты должна быть arity-3. Также, указав none в заголовке функции вызовет выполнение этого предложения только при явном совпадении соответствующего аргумента, используйте _ вместо аргументов, которые вас не волнуют, например:

Res = fun(Fetched,_,_)-> [X || X <- binary_to_term(riakc_obj:get_value(Fetched)), X rem 2 == 0] end.