Я использую Cassandra 1.0.5 + новейшую Fluent Cassandra для своего приложения на C #.
Я последовал примеру (с небольшой собственной модификацией) на сайте Fluent Cassandra, но получил исключение под названием «Apache.Cassandra.UnavailableException».
Я новичок в Кассандре, просто хочу быстро пробежаться по нему, чтобы почувствовать. Так может ли кто-нибудь сказать мне, почему?
Мой простой код такой:
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);
}
}