создание Keyspace - PullRequest
Новая
       9

создание Keyspace

2 голосов
/ 13 февраля 2012

Я пытаюсь получить доступ к Кассандре из Эрланга, в качестве теста я пытаюсь создать новое пространство ключей.Я делаю это следующим образом:

1> rr (cassandra_thrift). 

[authenticationException,authenticationRequest,
 authorizationException,cfDef,column,columnDef,
 columnOrSuperColumn,columnParent,columnPath,counterColumn,
 counterSuperColumn,cqlMetadata,cqlResult,cqlRow,deletion,
 endpointDetails,indexClause,indexExpression,
 invalidRequestException,keyCount,keyRange,keySlice,ksDef,
 mutation,notFoundException,schemaDisagreementException,
 slicePredicate,sliceRange,superColumn|...]

2> {ok, C1} = thrift_client_util: new ("127.0.0.1 ", 9160, thrift_cassandra, []). 

{ok,{tclient,thrift_cassandra,
        {protocol,thrift_binary_protocol,
            {binary_protocol,
                {transport,thrift_buffered_transport,
                    {buffered_transport,
                        {transport,thrift_socket_transport,
                            {data,#Port<0.593>,infinity}},
                        []}},
                true,true}},
        0}}

3> Reply1 = thrift_client: call (C1, set_keyspace, [" Test_KS "]). 

** exception exit: undef
     in function  thrift_cassandra:function_info/2
        called as thrift_cassandra:function_info(set_keyspace,params_type)
     in call from thrift_client:send_function_call/3 (thrift_client.erl, line 70)
     in call from thrift_client:call/3 (thrift_client.erl, line 40)

Я что-то не так делаю, или у моего эрланга нет доступа к функциям кассандры?Как я могу это исправить?

1 Ответ

2 голосов
/ 14 февраля 2012

Я бы использовал https://github.com/ostinelli/erlcassa вместо сырого Thrift от Erlang.

...