問題タブ [streaminsight]

ユーザー定義演算子でいくつかの計算を実行するいくつかのスタンディング クエリを持つ StreamInsight 1.2 の上に構築されたアプリケーションがあります。ときどき、計算の 1 つが完了するまでに比較的長い時間 (数秒) かかることがあり、他のクエリの実行がブロックされていることがわかります。私は StreamInsight の仕組みにあまり詳しくないので、このことから、すべてのクエリが単一のスレッドで実行されると推測しています。クエリを並行して実行する方法はありますか?

クエリを別々のスレッドに配置する以外に、散発的に長時間実行されるクエリが他のクエリをブロックするのを防ぐためにできることはありますか?

新しい StreamInsight 2.1 のリアクティブ拡張モデルを使用して動的クエリを作成する方法についての情報を探しています。具体的には、IQStreamable で CreatQuery() メソッドまたは同様のもの (IQueryable 内) を使用したいと考えています。作成中のワークフロー内で、この新しいクエリは StreamInsight にスタンディング クエリとして挿入されます。私はかなりの調査を行いましたが、解決策は見つかりませんでした。また、ほとんどのドキュメンテーションは、現在の「レガシー」アダプター モデルを参照しているようです。どんな助けでも大歓迎です。

C# で Microsoft StreamInsight を使用しました。Microsoft StreamInsight は C++ もサポートしていますか?

StreamInsight for CEP を数か月使用しており、ASA への移行に関心があります。ASA のドキュメントでは答えられない質問があります。StreamInsight では、イベントの期間を変更して、個別のポイント イン タイム イベントからシグナル ストリームを作成できます。例えば

私がやろうとしているのは、この高/低タイプの信号と特定の時点のイベントの別のストリームとの間のオーバーラップを検出することです。ASA で同じことを達成するにはどうすればよいですか?

背景: 複数のソースから Azure イベント ハブにイベントを送信するデバイスがあります。これらのイベントの一部は、連絡先からのオン/オフ イベントです。各連絡先タイプは「EventCode」で表され、「値」フィールドは連絡先が開いているか閉じているかを示します。私が探しているのは、EventCode X も「オン」状態であると同時に、EventCode 512 が「オン」状態であることを教えてくれる ASA クエリです。

解決

以下は、スイッチが開いているときに連絡先が閉じていることを検出する @Andrew からの変更されたコードです。「inStream」は、タイムスタンプ フィールドによってタイムスタンプが付けられた WITH ステートメントで定義されます。

私は StreamInsight サーバーを持っています。これは、スタンディング クエリによってデータをストリーミングします。StreamInsight の実行中にそのサーバーを再起動します。サーバーの再起動後、StreamInsight を古いスタンディング クエリで引き続き実行したいと考えています。

それをしてもいいですか ？できる場合、どうすればよいですか？

StreamInsight サーバーを持っています

StreamInsight クライアント A:

別のクライアント B があり、クライアント B のクエリをクライアント A のこのプロセスにバインドしたい (プロセスの名前は"serverProcess_Client_A"です)。クライアント B から新しいプロセスを作成したくない

質問: できますか?

別の質問: StreamInsight の既存のプロセスにクエリをバインドできますか?