私はCassandraとThriftライブラリでいくつかの作業を行っています。これらは非常に初期のライブラリであり、（間違いなく）ある時点で変更されることを私は理解しています。
次のリンクを使用して、Cassandraサーバー（ローカルVirtualBoxのUbuntuサーバーインスタンスで実行している）との間で読み書きするC＃コードの設定を支援しています。簡単な読み取り/書き込み機能が機能することを確認しました。
問題が発生しているのは、次のメソッド（Cassandraに付属のthrift.definitionファイルを使用して生成されたもの）を実行することです。
public void send_get_count(string keyspace, string key, ColumnParent column_parent, ConsistencyLevel consistency_level)
これが私のセットアップコードです：
TTransport _transport;
TProtocol _protocol;
Cassandra.Client _client;
public Test()
{
_transport = new TSocket("192.168.56.101", 9160);
_protocol = new TBinaryProtocol(_transport);
_client = new Cassandra.Client(_protocol);
}
私の呼び出しコードは次のようになります。
public void GetAllBlogEntries()
{
var timestamp = DateTime.Now.Millisecond;
var keyspace = "Keyspace1";
var utf8Encoding = System.Text.Encoding.UTF8;
var columnParent = new ColumnParent() {Column_family = "BlogEntries"};
var predicate = new SlicePredicate()
{
Slice_range = new SliceRange()
{
Start = new byte[0],
Finish = new byte[0],
Count = 10,
Reversed = false
}
};
var results = _client.get_range_slice(keyspace, columnParent, predicate, "", "", 5, ConsistencyLevel.ONE);
foreach(var slice in results)
{
Console.WriteLine("Found Key: {0}", slice.Key);
foreach(var resultColumn in slice.Columns)
{
var column = resultColumn.Column;
Console.WriteLine("\tName: {0}, value: {1}",
utf8Encoding.GetString(column.Name),
utf8Encoding.GetString(column.Value));
}
}
}
このメソッドの最初の行は、例外を取得しているところです。
oprot_.WriteMessageBegin(new TMessage("get_count", TMessageType.Call, seqid_));
そしてここに例外があります：
Thrift.Transport.TTransportException：Thrift.Protocol.TBinaryProtocol.WriteI32（Int32 i32）at Thrift.Protocol.TBinaryProtocolのThrift.Transport.TStreamTransport.Write（Byte [] buf、Int32 off、Int32 len）のnull出力ストリームに書き込めません。 Cassandra.csのApache.Cassandra.Cassandra.Client.send_get_range_slice（String keyspace、ColumnParent column_parent、SlicePredicate predicate、String start_key、String finish_key、Int32 row_count、ConsistencyLevelconsistency_level）のWriteMessageBegin（TMessageメッセージ）：Apache.Cassandra.Cassの341行目.Client.get_range_slice（String keyspace、ColumnParent column_parent、SlicePredicate predicate、String start_key、String finish_key、Int32 row_count、ConsistencyLevelconsistency_level）in Cassandra.cs：line 335 at CassandraDemo.Models.Test.GetAllBlogEntries（）in Test.cs：line 212 CassandraDemo.Tests.Modelsで。TestTest.csのTestTest.Test_GetAllBlogEntries_Success（）：42行目
何か案は？