2

我正在为我的 C# 应用程序使用 Cassandra 1.0.5 + 最新的 Fluent Cassandra。

我遵循了 Fluent Cassandra 站点中的示例（我自己做了一些修改），但我遇到了一个名为“Apache.Cassandra.UnavailableException”的异常。

我是 Cassandra 新手，只是想快速简单地运行一下以感受一下。那么任何人都可以告诉我为什么吗？

我的简单代码是这样的：

public class CassandraAPI
{
   private CassandraContext cassandraDB;
   private CassandraColumnFamily<BytesType> family;
   public CassandraAPI()
   {
      cassandraDB = new CassandraContext(keyspace: "MyKeyspace", host: "192.168.178.32");
      family = cassandraDB.GetColumnFamily<BytesType>("ColumnFamilyName");
   }

   public void update(byte[] key1, byte[] value)
   {
      dynamic post = family.CreateRecord(key: key1);
      post.value = value;
      // attach the post to the database
      Console.WriteLine("attaching record");
      cassandraDB.Attach(post);

      // save the changes
      Console.WriteLine("saving changes");
      cassandraDB.SaveChanges();
   }

   public void read(byte[] key)
   {
     dynamic getPost = family.Get(key).FirstOrDefault();
     Console.WriteLine("getPost");
     byte[] value = getPost.value;
     Console.WriteLine(value.Length);
   }
}
4

1 回答 1

4

UnavailableException 表示您请求的 ConsistencyLevel 无法满足。详情见：

http://wiki.apache.org/cassandra/API#Exceptions

您向其发出请求的集群有多大？这在本地单实例集群上是一个不寻常的错误。

于 2011-12-16T18:50:24.647 回答