問題タブ [streaminsight]

自己ホスト型の MSSI サーバーに展開されたプロセスがあります。このプロセスにバインドされた単純なパススルー クエリがあります。

一部のイベントはここにドロップされます "cep:/Server/Application/Erp/Entity/Event_Events_Process1/Query/StreamableBinding_1/Operator/Stream_1_CleanseInput"

ドロップされたイベントのカウンターが上昇していることがわかりますが、ドロップしている理由がわかりません。

誰もそれをデバッグする方法を知っていますか?

すべてのイベントを保持し、必要に応じて StreamInsight でイベントを追加または削除する方法はありますか? Esper には、ウィンドウに適用できる keepall() というメソッドがあります。このメソッドはすべての着信イベントを保持し、ウィンドウにイベントを挿入したり削除したりするためのさまざまなクエリを使用できます。

HoppingStreamInsight で、Snaphot、Tumblingおよびを使用してみCount Windowましたが、上記の機能はありません。

ありがとう。

データベースから読み取った入力ストリームがあり、さまざまなデバイスからの測定値があります。データベースに記録されたイベントは時系列ではありませんが、通常は 2 分のウィンドウで到着します。ただし、一部のデバイスでは、タイムスタンプが数日前のデータを送信できます。

入力ストリームに CTI を挿入して、せいぜい数分しか経過していない「通常の」データを処理する場合、残りのデータより数日遅れているデバイスのデータを処理するにはどうすればよいですか?

CTI を挿入する前に、入力ストリームをデバイスごとに 1 つのストリームに分割して、「古い」ストリームに他の入力ストリームから独立した CTI を持たせることはできますか?

前もって感謝します。

UnitId と Start Date で識別される複数の「ユニット」からのポイント データを含むポイント ストリームがある場合:

var input = CepStream<EventPayload>.Create("input", typeof(SQLPayloadInputAdapterFactory), inputConfig, EventShape.Point);

そして、それをインターバルストリームに変換します:

var signal = input .AlterEventDuration(e => TimeSpan.MaxValue) .ClipEventDuration(input, (e1, e2) => (e1.UnitID == e2.UnitID));

出力アダプターがイベント オブジェクトを認識し、その開始値と終了値を読み取ることができるため、出力アダプターによって読み取られると、シグナル ストリーム内のイベントの期間を取得できます。

私がする必要があるのは、「シグナル」ストリームを照会して、1 分間のタンブリング ウィンドウで最長のイベントを見つけることです。

...カウントなどを含むユニットのグループを提供しますが、イベントの期間を取得して他のクエリに渡すことはできませんgroupWindowQuery。

イベント プロパティをクエリして、タンブリング ウィンドウで最長のイベントを見つけるにはどうすればよいですか?

または、ペイロードに値を設定して、ポイントから信号ストリームを作成するときにポイント イベントに終了日を与えることはできますか?

(ウィンドウにまたがるイベントの期間が 1 分であることは問題ではありません)

Microsoft StreamInsight を試してもらうことを主な目的として、小さなプロジェクトを完了しました。

この技術は問題ないように見えますが、業界での牽引力について懸念があります。私たちが問題に遭遇したとき、ウェブ上にはほんの一握りの資料しかありませんでした。一般的に、その周りの活発なコミュニティが恋しいです.

StreamInsight の使用を拡大する必要がありますか? それとも、Silverlight のように数年で無駄になりますか?

私は、C# の世界と、IObservable 用語集に関連する専門用語は初めてだと考えてください。Current から情報を抽出する方法について質問があります。ここに私のC＃コードがあります：

ソースでこのクラスの値を渡すと:

現在の表現から x、Id、Level のいずれかの値を抽出する簡単な方法はありますか?

ありがとう

私は Microsoft BI 開発者であり、クライアントの 1 人のために複雑なイベントを処理するためのツールの評価プロセスを行っています。私は、WSo2、Jboss + drools、Nesper、Microsoft StreamInsight など、さまざまなバックグラウンドを持つ多くのツールに出会いました。また、Microsoft SQL Server のバックグラウンドを持っているため、Microsoft ツールのみを好みます。このツールを最終決定する前に、1 秒あたりの Streaminsight イベント処理容量の制限が懸念されます。標準バージョンでは 1 秒あたり 5000 ですが、現在 1 秒あたり 15000 ～ 20000 (今後数年でさらに増加) のイベントを探してい
ます。したがって、私の質問は、複数の Streamlight サーバーをクラスター化して、1 秒あたりのイベントを処理する容量を追加
できるかどうかです。必要な場合は、「複数の Streaminsight サーバーをクラスター化する方法」という知識を得る場所を教えてください。