Я работаю с Кассандрой и библиотеками Thrift. Я понимаю, что это очень ранние библиотеки и (несомненно) изменится в какой-то момент.
Я использовал следующую ссылку для помощи в настройке моего кода C # для записи и чтения с моего сервера Cassandra и с него (который я запускаю в экземпляре Ubuntu Server в моем локальном VirtualBox) , Я подтвердил, что тривиальная функция чтения / записи работает.
При возникновении проблемы выполняется следующий метод (который был сгенерирован для меня с помощью файла thrift.definition, поставляемого с Cassandra):
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.Transport.TStreamTransport.Write (Bute [] buf, Int32 выключено, Int32 len)
в Thrift.Protocol.TBinaryProtocol.WriteI32 (Int32 i32)
в Thrift.Protocol.TBinaryProtocol.WriteMessageBegin (сообщение TMessage)
в Apache.Cassandra.Cassandra.Client.send_get_range_slice (Пространство ключей, ColumnParent column_parent, Предикат SlicePredicate, String start_key, String finish_key, Int32 row_count, ConsistencyLevel consistency_level) в Cassandra.cs: строка 341
в Apache.Cassandra.Cassandra.Client.get_range_slice (Строковое пространство ключей, ColumnParent column_parent, Предикат SlicePredicate, String start_key, String finish_key, Int32 row_count, ConsistencyLevel consistency_level) в Cassandra.cs: строка 335
в CassandraDemo.Models.Test.GetAllBlogEntries () в Test.cs: строка 212
в CassandraDemo.Tests.Models.TestTest.Test_GetAllBlogEntries_Success () в TestTest.cs: строка 42
Есть идеи?