1

StreamInsight2.1を使用してStreamInsightアプリケーションに取り組んでいます。

入力アダプターは、1秒あたり数千のイベントを含むライブストックデータストリームになります。同じデータストリームを使用して複数の独立したクエリを実行し、ストリームの実行中にさらにクエリを追加して、ストリーム内の現在の場所で取得できるようにしたい。

ただし、クエリを作成するたびに、まったく新しい入力アダプタが作成されます。したがって、25個の入力アダプターがすべて同じデータをロードおよびプッシュすることになります。

私はこれを間違って考えているだけですか？入力アダプタは各クエリから独立していますか？

ライブストックデータを入力アダプターの背後に置き、各入力アダプターにそのデータを再度ストリーミングさせる唯一のソリューションはありますか？

どんなアドバイスも素晴らしいでしょう、StreamInsightに関する良いドキュメントを見つけるのは難しいです。

4

1 に答える 1

1

入力アダプターについて話しているので、新しいイベントソース/シンクアプローチではなく、レガシーアダプターモデルを使用していると想定しています。「動的クエリ構成」またはDQCと呼ばれるものを確認する必要があります。このアプローチでは、入力アダプターの単一インスタンスを作成してから、ストリームを他のクエリと共有できます。

一言で言えば、すべての株式相場表示データを含む「ソース」クエリを作成する必要があります。そこから、クエリで「ToStream（）」を呼び出して、クエリの結果をCepStreamに戻すことができます。次に、25ほどの他のクエリ/計算などで、そのストリームをデータソースとして使用します。

MSDNStreamInsightドキュメントの「実行時のクエリの作成」を参照してください。そのページの最初のセクション「既存のクエリの出力の再利用」は、まさに必要なものである必要があります。

于 2012-10-11T04:49:47.600 に答える