7

我正在使用 Cassandra 和 Thrift 库做一些工作。我意识到这些是非常早期的库，并且（毫无疑问）会在某个时候发生变化。

我一直在使用以下链接来帮助设置我的 C# 代码以在我的 Cassandra 服务器（我在本地 VirtualBox 的 Ubuntu Server 实例中运行）写入和读取。我已经确认微不足道的读/写功能有效。

我遇到问题的地方是执行以下方法（使用 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) 的 Thrift.Protocol.TBinaryProtocol 的 Thrift.Transport.TStreamTransport.Write(Byte[] buf, Int32 off, Int32 len) 写入空输出流。在 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, ConsistencyLevel 一致性_level) 中的 WriteMessageBegin(TMessage 消息)：Apache.Cassandra.Cassandra 的第 341 行Cassandra.cs 中的 .Client.get_range_slice(String keyspace, ColumnParent column_parent, SlicePredicate predicate, String start_key, String finish_key, Int32 row_count, ConsistencyLevel 一致性_level)：CassandraDemo.Models.Test.GetAllBlogEntries() 中的第 335 行 Test.cs：第 212 行在 CassandraDemo.Tests.Models。TestTest.cs 中的 TestTest.Test_GetAllBlogEntries_Success()：第 42 行

有任何想法吗？

4

1 回答 1

14

您需要在传输上调用 Open()。

于 2010-03-10T06:58:11.927 回答