win of windowを使用した場合のCPU /メモリの使用量が高い：時間

Question

私のアプリケーションでは、CEPエンジンとしてNesperを使用してイベントを処理しています。

私は、次のEPL文をモデル化しようとしています：

• イベントのValueフィールドは限られた窓の時間平均されています。
• これらの平均値のいずれかが1の値に一致すると、イベントが生成されます。

私はこれをモデル化しました：

SELECT (
(AVG(ParameterEvent1.Value) = 1) OR 
(AVG(ParameterEvent2.Value) = 1) 
... 
(AVG(ParameterEvent50.Value) = 1) 
) AS BooleanValue 
FROM 
ParameterEvent(Id = 1).win:time(3 sec) AS ParameterEvent1, 
ParameterEvent(Id = 2).win:time(3 sec) AS ParameterEvent2 
... 
ParameterEvent(Id = 50).win:time(3 sec) AS ParameterEvent50 

そして、別のスレッドで、私は50イベント/秒の安定した速度でエンジンにパラメータ値を供給しています。

この設定は、com.espertech.esper.client.EPException: ReaderWriterLock timeout expired例外が発生するまで、巨大なCPUとRAMの使用を引き起こします。

私はこの問題を引き起こしているのだろうか。 ウィンドウをwin:time(3 sec)からstd:lastevent()に変更すると、この問題は解決します。しかし、イベントを生成する前に、パラメータの値が1から3秒であることを確認するためのウィンドウが必要です。

完全なデモコードは次のとおりです。あなたはそれを実行するためにNesperパッケージをインストールする必要があります。

using System; 
using System.Collections.Generic; 
using System.Linq; 
using System.Text; 
using System.Threading.Tasks; 
using com.espertech.esper.client; 

namespace NesperTester 
{ 
    class Program 
    { 
     public class ParameterEvent 
     { 
      public int Id { get; set; } 
      public int Value { get; set; } 
     } 

     static EPServiceProvider engine; 

     const int NParameters = 50; 

     static void Main(string[] args) 
     { 
      engine = EPServiceProviderManager.GetDefaultProvider(); 

      engine.EPAdministrator.Configuration.AddEventType("ParameterEvent", typeof(ParameterEvent)); 

      CreateEPLStatement(); 

      Task.Factory.StartNew(() => SimulateParameterChange(), TaskCreationOptions.LongRunning); 

      System.Threading.Thread.Sleep(int.MaxValue); 
     } 

     static void CreateEPLStatement() 
     { 
      const int windowLength = 3; 

      var sb = new StringBuilder(); 

      for (int i = 1; i <= NParameters; i++) 
      { 
       sb.AppendFormat("(AVG(ParameterEvent{0}.Value) = 1) OR ", i); 
      } 

      var rule = sb.ToString(); 
      rule = rule.Remove(rule.Length - 4, 4); 
      sb.Clear(); 

      for (int paramId = 1; paramId <= NParameters; paramId++) 
      { 
       sb.AppendFormat("ParameterEvent(Id = {0}).win:time({1} sec) AS ParameterEvent{0}, ", paramId, windowLength); 
       //sb.AppendFormat("ParameterEvent(Id = {0}).std:lastevent() AS ParameterEvent{0}, ", paramId, windowLength); 
      } 

      var selectSources = sb.ToString(); 
      selectSources = selectSources.Remove(selectSources.Length - 2, 2); 

      var eplStr = string.Format("SELECT ({0}) AS BooleanValue FROM {1}", rule, selectSources); 

      var statementName = string.Format("statement1"); 

      var statement = engine.EPAdministrator.CreateEPL(eplStr, statementName, null); 
      statement.Start(); 
      statement.Events += Statement_Events; 
     } 


     static bool PrevState = false; 
     static void Statement_Events(object sender, UpdateEventArgs e) 
     { 
      var underlying = e.NewEvents[0].Underlying as Dictionary<string, object>; 

      if (underlying.Last().Value == null) 
      { 
       Console.WriteLine("Statement value is unknown"); 
      } 
      else 
      { 
       var statementValue = (bool)underlying.First().Value; 

       if (statementValue != PrevState) 
       { 
        PrevState = statementValue; 
        Console.WriteLine("Statement is {0}", statementValue); 
       } 
      } 
     } 

     static void SimulateParameterChange() 
     { 
      int counter = 0; 

      while (true) 
      { 
       for (int i = 1; i <= NParameters; i++) 
       { 
        var evt = new ParameterEvent(); 

        evt.Id = i; 

        if (i == 1 && (counter/4) % 2 == 0) 
        { 
         evt.Value = 1; 
        } 
        else 
        { 
         evt.Value = 0; 
        } 

        engine.EPRuntime.SendEvent(evt); 

        System.Threading.Thread.Sleep(1000/NParameters); 
       } 

       counter++; 
      } 
     } 
    } 
} 

Answer 1

はhttp://espertech.com/esper/solution_patterns.php#expiry-3 トリガするための「持つ」節を参照してください。