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