6

我们有一个包含流媒体视频的网站，我们希望显示上周、月和年（滚动窗口）中观看次数最多的视频的三份报告。

每次观看视频时，我们都会在 ravendb 中存储一个文档：

public class ViewedContent
{
    public string Id { get; set; }
    public int ProductId { get; set; }
    public DateTime DateViewed { get; set; }
}

我们在弄清楚如何定义最能支持生成这三个报告的索引/mapreduce 时遇到了麻烦。

我们尝试了以下 map/reduce。

public class ViewedContentResult
{
    public int ProductId { get; set; }
    public DateTime DateViewed { get; set; }
    public int Count { get; set; }
}

public class ViewedContentIndex :
        AbstractIndexCreationTask<ViewedContent, ViewedContentResult>
{
    public ViewedContentIndex()
    {
        Map = docs => from doc in docs
                      select new
                                 {
                                     doc.ProductId,
                                     DateViewed = doc.DateViewed.Date,
                                     Count = 1
                                 };

        Reduce = results => from result in results
                            group result by result.DateViewed
                            into agg
                            select new
                                       {
                                           ProductId = agg.Key,
                                           Count = agg.Sum(x => x.Count)
                                       };
    }
}

但是，此查询会引发错误：

var lastSevenDays = session.Query<ViewedContent, ViewedContentIndex>()
                .Where( x => x.DateViewed > DateTime.UtcNow.Date.AddDays(-7) );

错误：“DateViewed 未编入索引”

最终，我们要查询如下内容：

var lastSevenDays = session.Query<ViewedContent, ViewedContentIndex>()
                .Where( x => x.DateViewed > DateTime.UtcNow.Date.AddDays(-7) )
                .GroupBy( x => x.ProductId )
                .OrderBy( x => x.Count )

这实际上并没有编译，因为 OrderBy 是错误的；Count 在这里不是一个有效的属性。

这里的任何帮助将不胜感激。

4

1 回答 1

11

如果您在 SQL 领域，每个报告都是不同的 GROUP BY，它告诉您需要三个索引 - 一个仅包含月份，一个包含每周条目，一个包含月份，一个包含年份（或者可能略有不同，具体取决于关于你实际上将如何进行查询。

现在，您在那里有一个 DateTime - 这会带来一些问题 - 您真正想要做的是索引 DateTime 的 Year 组件、日期时间的 Month 组件和该日期时间的 Day 组件。（或者只是其中的一两个，具体取决于您要生成的报告。

我只是在这里引用你的代码，所以显然它不会编译，但是：

public class ViewedContentIndex :
    AbstractIndexCreationTask<ViewedContent, ViewedContentResult>
{
public ViewedContentIndex()
{
    Map = docs => from doc in docs
                  select new
                             {
                                 doc.ProductId,
                                 Day = doc.DateViewed.Day,
                                 Month = doc.DateViewed.Month,
                                 Year = doc.DateViewed.Year
                                 Count = 1
                             };

    Reduce = results => from result in results
                        group result by new {
                             doc.ProductId,
                             doc.DateViewed.Day,
                             doc.DateViewed.Month,
                             doc.DateViewed.Year
                        }
                        into agg
                        select new
                                   {
                                       ProductId = agg.Key.ProductId,
                                       Day = agg.Key.Day,
                                       Month = agg.Key.Month,
                                       Year = agg.Key.Year  
                                       Count = agg.Sum(x => x.Count)
                                   };
}

}

希望你能看到我试图通过这个实现的目标——你想要你组中的所有组件，因为它们使你的分组独一无二。

我不记得 RavenDB 是否允许您使用 DateTimes 执行此操作，而我在这台计算机上没有它，因此无法验证这一点，但理论保持不变。

所以，重新迭代

您想要一个按周 + 产品 ID 的报告索引 您想要一个按月 + 产品 ID 的报告索引 您想要一个按年份 + 产品 ID 的报告索引

我希望这会有所帮助，对不起，我不能给你一个可编译的例子，缺少乌鸦让它有点困难:-)

于 2011-03-23T21:48:14.093 回答