Блог

У меня есть приведенный ниже код, который отлично работает для меня. Для демонстрационных целей я добавляю в список только несколько записей в режиме реального времени, этот список постоянно пополняется новыми значениями в секунду. вопрос в том, как сортировать эти данные в реальном времени на основе временного интервала? Размещенный ниже код в постоянно работающем webjob.

 public class MyObject 
{
    public double Value { get; set; }
    public DateTime Time { get; set; }

    public DateTime GetStartOfPeriodByMins(int numMinutes) 
    {
        int oldMinutes = Time.Minute;
        int newMinutes = (oldMinutes / numMinutes) * numMinutes;

        DateTime startOfPeriod = new DateTime(Time.Year, Time.Month, Time.Day, Time.Hour, newMinutes, 0);

        return startOfPeriod;
    }
}


List<MyObject> inputList = new List<MyObject>();

inputList.Add(new MyObject() {Time = new DateTime(2020, 10, 10, 9, 15, 0), Value = 12});
Thread.Sleep(1000);
inputList.Add(new MyObject() {Time = new DateTime(2020, 10, 10, 9, 15, 2), Value = 11});
Thread.Sleep(1000);
inputList.Add(new MyObject() {Time = new DateTime(2020, 10, 10, 9, 15, 5), Value = 13});
Thread.Sleep(1000);
inputList.Add(new MyObject() {Time = new DateTime(2020, 10, 10, 9, 15, 15), Value = 14});
Thread.Sleep(1000);
inputList.Add(new MyObject() {Time = new DateTime(2020, 10, 10, 9, 15, 45), Value = 12});
Thread.Sleep(1000);
inputList.Add(new MyObject() {Time = new DateTime(2020, 10, 10, 9, 15, 55), Value = 11});
Thread.Sleep(1000);
inputList.Add(new MyObject() {Time = new DateTime(2020, 10, 10, 9, 16, 0), Value = 13});
Thread.Sleep(1000);
inputList.Add(new MyObject() {Time = new DateTime(2020, 10, 10, 9, 16, 1), Value = 16});


var resultSet = inputList
    .GroupBy(i => i.GetStartOfPeriodByMins(1))
    .Select(gr =>
        new 
        {
            StartOfPeriod = gr.Key,
            Min = gr.Min(item => item.Value),
            Max = gr.Max(item => item.Value),
            Open = gr.OrderBy(item => item.Time).First().Value,
            Close = gr.OrderBy(item => item.Time).Last().Value
        });

var my = resultSet.ToList();
  

Временной интервал, взятый здесь, составляет 1 минуту, поэтому для каждой минуты он будет давать мне отдельные значения для открытия, максимума, минимума и закрытия этих минут.

Я хочу обрабатывать данные inputList так, чтобы через каждые 1 минуту я получал последний набор данных за последние 1 минуту, чтобы я мог использовать его для дальнейших вычислений.

Поскольку он продолжает вставки (add), вы можете использовать SortedSet вместо этого в списке.

 public class MyObjectComparer : IComparer<MyObject>
{
    public int Compare(MyObject x, MyObject y)
    {
        return x.Time.CompareTo(y.Time);
    }
}

var inputList = new SortedSet<MyObject>(new MyObjectComparer());

inputList.Add(new MyObject() {Time = new DateTime(2020, 10, 10, 9, 15, 0), Value = 12});
Thread.Sleep(1000);
inputList.Add(new MyObject() {Time = new DateTime(2020, 10, 10, 9, 15, 2), Value = 11});
Thread.Sleep(1000);
inputList.Add(new MyObject() {Time = new DateTime(2020, 10, 10, 9, 15, 5), Value = 13});
Thread.Sleep(1000);
inputList.Add(new MyObject() {Time = new DateTime(2020, 10, 10, 9, 15, 15), Value = 14});
Thread.Sleep(1000);
inputList.Add(new MyObject() {Time = new DateTime(2020, 10, 10, 9, 15, 45), Value = 12});
Thread.Sleep(1000);
inputList.Add(new MyObject() {Time = new DateTime(2020, 10, 10, 9, 15, 55), Value = 11});
Thread.Sleep(1000);
inputList.Add(new MyObject() {Time = new DateTime(2020, 10, 10, 9, 16, 0), Value = 13});
Thread.Sleep(1000);
inputList.Add(new MyObject() {Time = new DateTime(2020, 10, 10, 9, 16, 1), Value = 16});

  

Таким образом, для каждого добавления набор (список) будет в правильном порядке.

 public class MyObject 
{
    public double Value { get; set; }
    public DateTime Time { get; set; }
    
    public DateTime Created { get; } = DateTime.Now;
    public DateTime Ttl { get; } = DateTime.Now.AddMinues(5);
    public DateTime? Persisted { get; set; }

    public bool IsDead => DateTime.Now > Ttl;
    public bool IsPersisted => Persisted.HasValue;
    public bool TimeToPersist => IsPersisted == false amp;amp; DateTime.Now > Create.AddMinutes(2);

    public DateTime GetStartOfPeriodByMins(int numMinutes) 
    {
        int oldMinutes = Time.Minute;
        int newMinutes = (oldMinutes / numMinutes) * numMinutes;

        DateTime startOfPeriod = new DateTime(Time.Year, Time.Month, Time.Day, Time.Hour, newMinutes, 0);

        return startOfPeriod;
    }
}