Thrift.Transport.TTransportException: impossible d'écrire dans le flux de sortie nul

Question

Je travaille avec Cassandra et les librairies Thrift. Je me rends compte que ce sont des bibliothèques très tôt et (sans aucun doute) changeront à un moment donné.

J'ai utilisé le link suivant pour aider à configurer mon code C# pour écrire et lire depuis et vers mon serveur Cassandra (que j'ai exécuté dans une instance d'Ubuntu Server dans mon VirtualBox local). J'ai confirmé que la fonctionnalité de lecture/écriture triviale fonctionne.

Là où je vais avoir un problème exécute la méthode suivante (qui a été généré pour moi en utilisant le fichier thrift.definition fourni avec Cassandra):

public void send_get_count(string keyspace, string key, ColumnParent column_parent, ConsistencyLevel consistency_level) 

Voici mon code de configuration:

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); 
} 

Mon code d'appel ressemble à ceci:

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));       
      } 
     } 
    } 

La première ligne de cette méthode est là Je reçois mon exception:

oprot_.WriteMessageBegin(new TMessage("get_count", TMessageType.Call, seqid_)); 

Et voici l'exception:

Thrift.Transport.TTransportException: ne peut pas écrire null outputstream à Thrift.Transport.TStreamTransport.Write (Byte [] buf, Int32 off, Int32 len) à Thrift.Protocol.TBinaryProtocol.WriteI32 (Int32 i32) à Thrift.Protocol.TBinaryProtocol.WriteMessageBegin (message TMessage) à 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 consis tency_level) dans Cassandra.cs: ligne 341 à Apache.Cassandra.Cassandra.Client.get_range_slice (Chaîne d'espace-clé, ColumnParent column_parent, Prédicat SlicePredicate, Chaîne start_key, Chaîne finish_key, Int32 row_count, ConsistencyLevel, niveau de cohérence) dans Cassandra.cs: ligne 335 à CassandraDemo.Models.Test.GetAllBlogEntries() dans Test.cs: ligne 212 à CassandraDemo.Tests.Models.TestTest.Test_GetAllBlogEntries_Success() dans TestTest.cs: ligne 42

Des idées?

Answer 1

Vous devez appeler Open() sur le transport.