問題タブ [streaminsight]

WCF 対応のソースとシンクを使用し、プロジェクトに埋め込まれた StreamInsight を使用してクエリを実行しています。クエリを実行しているときにソースを作成します。それは問題ありませんが、いくつかのデータ タプルがソースに入る (そしてシンクに到達する) まで、シンクは作成されません。したがって、クライアントは、入力データがクエリに到達する前に (WCF 経由で) シンクに接続できません。どうすればこの問題を解決できますか?!

を使用しIQStreamableて作成されたオブジェクトがあります。DefineObservableMicrosoft.ComplexEventProcessing.Application

Task.Run()コードは正常に見えますが、渡された引数 from intoを使用するDefineObservableと、例外が発生することがわかりません。

ただし、プロパティを内部のメソッドに渡さずに直接使用するとTask.Run()、機能しました。

例外

An unhandled exception of type 'System.InvalidOperationException' occurred in Microsoft.ComplexEventProcessing.Diagnostics.dll

Additional information: Cannot serialize value of type 'System.IObservable'1[ValueObjects.Price]'.

メソッド

呼び出し：

質問：

1. StreamInsight はオブザーバー オブジェクトをシリアル化しますか? なぜ？

2. 違いは何ですか

これ .DefineObservable<Price>(() => PriceObservable) と

これ DefineObservable<Price>(() => PriceRealtimeProvider.Instance.PriceObservable)

引数を使用すると問題が発生するのはなぜですか?

1 秒あたり 8000 を超えるイベントが配信される状況で、StreamInsight エンジンが 140 を超えるイベント/秒を処​​理できない理由がわかりません。クエリのイベント数/秒がパフォーマンス モニターに表示されます。アプリケーションのコンソールでは、エンジンが多くのイベントを回避するようになっています。ID: 200 のイベントがあり、次に ID: 3330 のイベントがあります。何が問題なのか知っている人はいますか?

私のテストでは、一連のクエリがあります。最初のクエリの出力は 2 番目のクエリの入力であり、このシナリオでは、結果は 140 イベント/秒を超えません。

ここで、入力ストリームから受信したすべてのイベントを出力する単純なクエリを使用してアプリケーションをテストしました。この状況では、サーバーは約 2000 イベント/秒を処​​理します。結果の画像がいくつかありますが、残念ながらまだ掲載できません。私が気になるのは、イベント/秒の量が突然 0 に減少した理由と、エンジンがまだすべての入力イベントを考慮していない理由です。

これが私のサーバー構成と私が使用しているクエリです。

次に、(チェーンから) 最後のクエリを実行しようとしたとき、約 1500 イベント/秒を取得しました。それでも、イベント/秒の突然の減少に問題があります。イベントに対して行われる各変換は、エンジンによって処理される必要がある新しいものを生成すると考えました。したがって、一連のクエリからのイベント/秒の数は 1500 を超えるはずです。間違っている場合は修正してください。私はこのドメインに不慣れで、アドバイスは大歓迎です。

問題は以下のクラスにあると思います。PointEvent<SendorDataEvent>の代わりにもSensorDataEvent試し、CTI も挿入しようとしましたが、結果はありませんでした。

ありがとうございました。

いくつかの Reactive Extension クエリを StreamInsight に移植する作業を行っていますが、ウィンドウ クエリが重複しているという問題が発生しました。

StreamInsight サーバーにソース セットアップがあり、次のようなオーバーラップ ウィンドウ クエリを作成しようとしています。

ソースはどこにありIQbservable<EventPattern<MyEventArg>>、クエリは次にIQbservable<IObserverable<EventPattern<MyEventArg>>>

Reactive では、オブザーバーは次のように作成されました。

オブザーバーをアタッチして、StreamInsight から同等の出力を取得するにはどうすればよいですか?

私はStreamInsight数週間作業してきましたが、通常、1つの例外を除いて、私がやりたいことを実行しています。同じプロセスで複数のクエリを実行することはできません。たとえば、次のeventStream場合IQStreamable<eventClass>:

これを実行すると、query1 のイベントの約半分のみが に送信されquery1Observer、query2 のイベントの約半分のみが に送信されquery2Observerます。他は消えるだけです。バインディングを作るだけなら

その後、すべてのクエリの結果がオブザーバーに通知されますが、もちろん query1 に対してのみです。同じプロセスで異なるオブザーバーに通知する 2 つのクエリを実行するにはどうすればよいですか?

何かが欠けているのでしょうか、それとも従来の BI ソリューションを SSAS/SSRS/SSIS に組み込むためのより簡単な方法が streaminsight でしょうか。

伝統的：

ストリームインサイト:

リアルタイム分析の機能がない従来の方法では、SSIS パッケージを再度実行する期間を常に定義する必要があります。ただし、CDC (Change Data Capture) を使用すると、ある程度リアルタイムになります。CDC はデータベースの変更をチェックし、SSIS パッケージを起動します。

StreamInsight は、リアルタイムの ETL ソリューションを提供します。

これは正しいですか？