Проблема с фильтром ключей в клиенте erlang pb - PullRequest
Новая
       7

Проблема с фильтром ключей в клиенте erlang pb

0 голосов
/ 25 июля 2011

UPDATE2 Я нашел решение (спасибо rvirding). Я должен поставить объект, как это 

Object = riakc_obj:new(list_to_binary(Bucket),
                       list_to_binary(Time),
                       list_to_binary(TimeValue)),
ok = riakc_pb_socket:put(Db_pid, Object);

И сделайте запрос вот так 

Query = [{map,                                                  %query type
             {modfun, riak_kv_mapreduce, map_object_value},         %function from riak erlang built-in module
             none, true}],
    Inputs = {Bucket, [[<<"between">>, <<"0">>, <<"0.05">>]]},
    Result = riakc_pb_socket:mapred(Pid, Inputs, Query),

Я думаю, это должно быть упомянуто в документации.

КСТАТИ! Если бы я написал 

Object = riakc_obj:new(<<Bucket>>,
               <<Time>>,
               <<TimeValue>>),

Я получил ошибку по поводу badarg. Все еще смущен этим. (

UPDATE

Если я напишу это 

Inputs = {Bucket, [[<<"between">>, 0, 1]]}

Я не получил ошибку, я даже получил "ок" результат, но он пустой, что не является ожидаемым поведением.)

=============================================== ================

Я полностью сошел с ума с этим, но я должен закончить это.

У меня есть простое приложение: оно извлекает данные из txt-файла (например, «значение метки времени»), отправляет его в Riak и делает несколько запросов диапазона. Проблема в том, что когда я делаю запрос фильтра ключей, я получаю {error, отключено}. Я обрабатывал данные в riak следующим образом: ключ - отметка времени (например, 0,43), значение - значение (например, 1,14), интервал - время добавления данных (например, «2011-07-24-23-39-45»). Вот код запроса:

(dca_db.erl) 

handle_call({range_query, Bucket, From, To}, _, #state{db_pid = Pid} = State) ->
    Query = [{map,                                                  %query type
             {modfun, riak_kv_mapreduce, map_object_value},         %function from riak erlang built-in module
             none, true}],
    Inputs = {Bucket, [["between", 0, 1]]},
    Result = riakc_pb_socket:mapred(Pid, Inputs, Query),
    {reply, Result, State};

(тест / dca_db_tests.erl) 

range_request(Pid) ->
Bucket = <<"2011-07-24-23-39-45">>,
Result = gen_server:call(Pid, {range_query, Bucket, 0, 1}),
error_logger:info_msg("RESULT:~p~n",[Result]).

Вы можете найти мой код в github - https://github.com/DimitryDushkin/distributed_calc_riak_matlab

Если я использую что-то вроде (в dca_db.erl) 

Inputs = {Bucket, [["eq", 1]]},

У меня есть другая ошибка 

Compiled src/dca_db.erl
undefined
*unexpected termination of test process*
::{{badmatch,{<<"2011-07-24-23-39-45">>,[["eq",1]]}},
   [{dca_db,handle_call,3},
    {gen_server,handle_msg,5},
    {proc_lib,init_p_do_apply,3}]}


=ERROR REPORT==== 25-Jul-2011::00:27:24 ===
** Generic server dca_db terminating 
** Last message in was {range_query,<<"2011-07-24-23-39-45">>,0,1}
** When Server state == {state,<0.105.0>}
** Reason for termination == 
** {{badmatch,{<<"2011-07-24-23-39-45">>,[["eq",1]]}},
    [{dca_db,handle_call,3},
     {gen_server,handle_msg,5},
     {proc_lib,init_p_do_apply,3}]}
=======================================================
  Failed: 0.  Skipped: 0.  Passed: 1.
One or more tests were cancelled.
Cover analysis: /Users/ddushkin/Documents/workspaces/eclipse/distributed_calc_riak_matlab/.eunit/index.html
ERROR: One or more eunit tests failed.
make: *** [test_db] Error 1

И все работает, если я не использую фильтры: 

Inputs = Bucket,

Спасибо.

1 Ответ

2 голосов
/ 25 июля 2011

Ведро и ключи к риаку должны быть двоичными, поэтому вы не получите ошибки. То, что вы ничего не находите, означает, что ведро / ключи неверны. Как они были созданы, когда данные были добавлены в БД? Убедитесь, что вы делаете это точно так же! В приложении, с которым я работал, они сделали term_to_binary(Key) для значения, но это можно сделать любым способом, который вы выберете.

...