项目中需要获取Cassendra中某个ColumnFamly所有的值,并且缓存起来。感谢Andy童鞋给了我很好的示例
代码背景:
这个ColumnFamly是Super的,SuperColumn是Year,Key是ID,每一个SuperColumn下面存放着不同的数据,比如MSR, Name,UpdateTime之类的。但我们这里只需要MSR,这个字段是整数,所以最终的示例代码如下:
public static Dictionary<string, int> GetLastestMSROfAllSchools()
{
//开始StartKey是空值
string startKey = "";
//最大每次返回的数据个数
int maxReturnCount = 500;
//最终的结果保存在这个字典里,这个是需要被缓存起来的
Dictionary<string, int> dictMSR = new Dictionary<string, int>();
//获取所有的数据
GetLatestMSRFromCassandra(startKey, maxReturnCount, ref dictMSR);
return dictMSR;
}
private static void GetLatestMSRFromCassandra(string startKey, int maxReturnCount, ref Dictionary<string, int> dictMSR)
{
string lastKey = string.Empty;
UTF8EncoderHelper utf8 = new UTF8EncoderHelper();
ConnectionString connString = new ConnectionString(DataAccessLib.CassandraAccess.ConnectionStringKeys.HouseHistory);
// Get MSR list in a given range.
List<CassandraKeySlice> listMSR = CassandraClient.GetRangeSliceCommand(connString, MSRProcessor.MSRColumnFamily, null, 100, maxReturnCount, startKey);
if(listMSR == null || listMSR.Count == 0)
return;
for (int i = 0; i < listMSR.Count; i++)
{
CassandraKeySlice cassandraKeySlice = listMSR[i];
string ncesSchoolId = lastKey = utf8.FromByteArray(cassandraKeySlice.Key);
// Order MSRs of a school by year descending. 根据SuperColumn排序
List<CassandraColumnOrSuperColumn> listOrderedMSR = cassandraKeySlice.Columns.OrderByDescending(x => utf8.FromByteArray(x.SuperColumn.Name)).ToList();
if(listOrderedMSR != null && listOrderedMSR.Count > 0)
{
//找到最近一年的MSR Column,饼获取它的值
CassandraColumn msrColumn = listOrderedMSR[0].SuperColumn.Columns.Find(x => utf8.FromByteArray(x.ColumnName) == MovotoSchoolRankSavedDataColumns.MSR);
if (msrColumn != null)
{
// 如果找到的话把它存到字典里面
int tempMSR = System.BitConverter.ToInt32(msrColumn.Value, 0);
if (!dictMSR.ContainsKey(ncesSchoolId))
dictMSR.Add(ncesSchoolId, tempMSR);
}
}
}
if(listMSR.Count < maxReturnCount)
return;
else
{
GetLatestMSRFromCassandra(lastKey, maxReturnCount, ref dictMSR);
}
}
分享到:
相关推荐
Cassandra相关教程,从基本的系统安装到编码使用。
cassandra 2.0.8 source code for eclipse (Linux 32bit) /usr/java /usr/apache-cassandra-2.0.8
The rising popularity of Apache Cassandra rests on its ability to handle very large data sets that include hundreds of terabytes -- and that's why this distributed database has been chosen by ...
这是在 goji 中使用 CassandraDB 的小例子 该项目使用 CassandraDB 在 Goji 上实现了简单的 REST API 在这里您可以找到 API 文档(俄语)
在NoSQL世界中有以下关键的成员,包括GoogleBigTable、HBase、HypertableAmazonDynamo、Voldemort、Cassendra、RiakRedisCouchDB、MongoDB。在过去几年,一种新兴的大型数据存储机制正吞噬大数据存储市场。这种存储...
本文提出了一种通过引入内存数据库层,建立两层多分区分布式数据库架构。此方案用于解决海量高并发系统的数据存储和访问问题,尤其适用于电子商务等数据...NoSQL、Key-Value引擎如BigTable、Cassendra等在很多大型网站