Cassandra Thrift Erlang insertar

Question

Actualmente estoy tratando de conseguir mi cabeza envolver alrededor de Cassandra/de segunda mano con Erlang ...

tengo una familia columna denominada "MQ" (como en la cola de mensajes) ...

Me gustaría tener una fila por usuario (con un user_id), cada mensaje sería una nueva columna con la marca de tiempo para el nombre y el mensaje como el valor.

Aquí es en Cassandra-cli lo que estoy haciendo:

create keyspace my_keyspace; 
use my_keyspace; 
create column family mq with comparator=UTF8Type and key_validation_class=UTF8Type; 

%% Adding to user_id (00000001) the message "Hello World!" 
set mq['00000001']['1336499385041308'] = 'Hello Wold'; 

Todo funciona muy bien con Cassandra-cli

Sin embargo, cuando estoy tratando de insertar de Erlang, estoy corriendo en una cierta edición:

1>rr(cassandra_types). 
2>{ok, C}=thrift_client_util:new("localhost", 9160, cassandra_thrift,[{framed, true}]). 
3>thrift_client:call(C, 'set_keyspace', ["peeem"]). 
4>thrift_client:call(C,'insert',["00000001", 
        #columnPath{column_family="mq"}, 
        #column{name="1336499385041308", value="Hello World!"}, 
        1 
        ] 
        ). 

Aquí está el error:

{error,{bad_args,insert, 
       ["00000001", 
       #columnPath{column_family = "mq",super_column = undefined, 
          column = undefined}, 
       #column{name = "1336499385041308",value = "Hello World!", 
         timestamp = undefined,ttl = undefined},1]}}} 

Cualquier ayuda se agradece ...

EDIT 1:

he descubierto que debería ser (ya que funciona para otra persona):

thrift_client:call(C,'insert', ["00000001", #columnParent{column_family="mq"}, #column{name="123456",value="Hello World!"}, 2]). 

Aquí está la mensaje de error relacionado:

** exception error: no match of right hand side value {{protocol,thrift_binary_protocol, 
                   {binary_protocol,{transport,thrift_framed_transport, 
                          {framed_transport,{transport,thrift_socket_transport, 
                                  {data,#Port<0.730>,infinity}}, 
                               [],[]}}, 
                        true,true}}, 
                 {error,closed}} 
    in function thrift_client:send_function_call/3 (src/thrift_client.erl, line 83) 
    in call from thrift_client:call/3 (src/thrift_client.erl, line 40) 

Answer 1

Ok he descubierto lo que fue el tema o temas que sean correctos ...

Aquí está mi código con el fin de conectar e insertar ...

rr(cassandra_types). 
{ok, C}=thrift_client_util:new("localhost", 9160, cassandra_thrift,[{framed, true}]). 
{C1, _} = thrift_client:call(C, 'set_keyspace', ["my_keyspace"]). 
thrift_client:call(C1,'insert', ["00000001", #columnParent{column_family="mq"}, #column{name="1234567",value="Hello World !", timestamp=0}, 2]). 

De hecho Debemos insertar en el nuevo thrift_client que devuelve 'set_keyspace' ... aparentemente, para cada llamada realizada a través de un ahorro, se genera y se debe usar un nuevo thrift_client.

Además, deberíamos usar columnParent en lugar de columnPath (aún no estoy seguro de por qué, simplemente funciona). Y la marca de tiempo en la columna # es obligatoria ...

Espero que esto ayude a otra persona.

Answer 2

recomiendo echar un vistazo a https://github.com/ostinelli/erlcassa i en lugar de reinventar la rueda de la lucha de ahorro.