5

我在使用 c# 和 FluentCassandra 从 Cassandra 获取一些数据时遇到问题。在我的 Cassandra 键空间中,我有以下超级列族定义:

<ColumnFamily Name="MySCFName"
                    ColumnType="Super"
                    CompareWith="TimeUUIDType"

                CompareSubcolumnsWith="AsciiType"/>

我想做的是在这个超列族上运行一个查询,类似于 sql 中的以下内容:

select "something" from MyTable where "timestamp" between "2011-01-01 00:00:00.000" and "2011-03-01 00:00:00.000"

按照一个教程,我发现我可以使用以下命令从 Cassandra 中获取一些数据:

family.Get("238028210009775").Fetch(DateTime.Parse("2011-01-01 00:00:00.000")).FirstOrDefault();

但这在sql中是等价的"timestamp" > "2011-01-01 00:00:00.000"

到目前为止,我无法弄清楚如何从一系列值中检索数据。

任何提示或帮助将不胜感激:) 在此先感谢,尼古拉

4

1 回答 1

5

您应该能够通过以下方式做到这一点:

using (var db = new CassandraContext(keyspace: "keyspace_name", host: "localhost"))
{
    var fromDate = DateTime.Now.Subtract(new TimeSpan(0, 30, 0));
    var toDate = DateTime.Now;
    var family = db.GetColumnFamily<TimeUUIDType, AsciiType>("family_name");
    var results = family.Get("row_key")
                        .Fetch(fromDate)
                        .TakeUntil(toDate)
                        .FirstOrDefault();
}
于 2011-03-30T13:57:13.683 回答