Sorting Sitecore Items by Popularity using xDB

ViewAggregationProcessor.cs

using System;
using System.Linq;
using Sitecore.Analytics.Aggregation.Pipeline;
using Sitecore.Diagnostics;

namespace Website.Logic.Analytics.Views
{
    public class ViewAggregationProcessor : AggregationProcessor
    {
        protected override void OnProcess(AggregationPipelineArgs args)
        {
            Assert.ArgumentNotNull(args, "args");

            if (args.Context.Visit.Pages == null)
                return;

            foreach (var page in args.Context.Visit.Pages)
            {
                if (page.PageEvents != null)
                {
                    var fact = args.GetFact<ViewFact>();
                    foreach (var pageEvent in page.PageEvents.Where(p => p.Name == "View"))
                    {
                        var viewKey = new ViewKey {
                            Date = pageEvent.DateTime.Date,
                            ItemId = pageEvent.ItemId
                        };

                        var viewValue = new ViewValue
                        {
                            Count = 1,
                            TemplateId = new Guid(pageEvent.Data)
                        };

                        fact.Emit(viewKey, viewValue);
                    }
                }
            }
        }
    }
}