問題タブ [streaminsight]

StreamInsight を使い始め、wcf サービスとして使用しています。私は既に " Microsoft StreamInsight クエリのヒッチハイク ガイド" で助けを求めようとし、例と codeplex の例を試しました。

私の問題はこれです：

私のイベント プロデューサーは、アダプターに AlertEvent をフィードします。

AlertEvent の IsError = false の場合、フラグ IsToNormalize は true です。

私が達成しようとしている動作は、IsError でストリームを受信したときです。次の「x」分で、IsToNormalize でアラートイベントが到着するかどうかを確認したいと思います。次に、検索を開始した IsError AlarmEvent を送信して出力します。

私が行ったことは、フィルターに対応する入力を受け取ったときに、その有効期間を「x」分延長し、TumblingWindow を作成して、その期間に別の AlertEvent が他のフラグで到着するかどうかを確認することです (ExtensionMethod を使用して反復します)。ウィンドウ内のすべてのペイロードを介して)。

次に、TumblingWindow をトリガーした AlarmEvent を取得するために、元の入力と結合しました。

これはまったく機能していません... :/ この問題の解決に役立つアイデアはありますか?

私が持っているもう1つの疑問は、フィルターを通過する入力ごとに新しいstartDateを持つ新しいウィンドウを作成するか、それともタンブリングウィンドウを1つだけ作成するかということです。

ありがとう。

I am looking for some possible options for streaming all changes happening on DB level using Microsoft StreamInsight. One possible way is using DB Triggers (which I don't thing is a good way). If anyone has some experience with this please suggest.

I am open to other products as well, what I really want to do is monitor data changes and raise corresponding events against them. Any help will be appreciated :)

Looking from the comments following details might help: We have an information system with few components written in C++, few in PowerBuilder, rest all in C#. They all sit on top of common database. In short, we don't have single entry point to database. What we are looking into right now is to add configurable rules which get fired based on Events. This can be easily achieved using 3rd party rules engine. Our only challenge right now is how to generate these events based on change of data. I read about 2 options from SQL Server side: Change Tracking Change Data Capture not sure even that can help. I was also trying to see how StreamInsight can help us achieve this. I hope this added more clarity to question.

イントラネットのセットアップでは、複数のクライアントがあり、それぞれが StreamInsight サーバーにデータを送信する必要があります。データはイベント ドリブンです。たとえば、ユーザーがページをクリックすると、そのデータ (どのユーザーがどのオブジェクトをクリックしたか) を streaminsight サーバーに送信する必要があります。

また、各クライアントは大量のデータを送信できるため、設計はスケーラブルである必要があります。

StreamInsight を初めて使用するので、クライアントから StreamInsight サーバーにそのデータを送信する方法を教えていただければ幸いです。

ありがとう

PS: より多くのことを見つけたり理解したりするたびに、これを更新し続けます。

単純なstreaminsightアプリをセットアップする際に、server.create（）が機能し、server.connect（）が失敗するという問題が発生しています。何が原因かわかりません。

編集：ここのソースコード：http：//pastebin.com/XigdxXLd

私のセットアップ：

• クライアントがデータを送信するプライベートmsmq
• サーバーは入力アダプターを使用してこのmsmqを読み取り、テキストファイルに出力を生成します

上記の設定で、streaminsightサーバーのメモリ内インスタンスを作成すると（を使用server.create("MyInstance")して、msmq内のすべてのメッセージを消費し、正常に動作します（server.disposeに配置するのが好きなので、アプリが終了するまでに約1分かかります） （）しばらくお待ちください）。

次を使用してserver.connectに切り替えると、次のようになります。

msmqのメッセージを1つだけ消費し、アプリは完了しません。プロジェクトは1分後にタイムアウトしapplication.Delete()ます（アプリケーションはMS.CEP.applicationです）。

誰かが私が間違っている可能性があることを手伝ってくれますか？

また、StreamInsightHost.exe.config最近ファイルを開こうとしましたが、メモ帳もVisualStudioでもファイルを開くことができませんでした。これが何かに影響を与える可能性があるかどうかはわかりませんが、私はそれをそこに出すと思っていました。

I/O アダプターは、StreamInsight サービスと同じコンピューターで実行する必要がありますか? つまり、StreamInsight をバックエンド サーバーで実行している間に、アプリケーション サーバーで入力アダプターを実行することは可能ですか?

ペイロードのウィンドウを出力アダプターに送信したいと考えています。それらすべてを 1 つずつではなく、同時に出力アダプターに送る必要があります。

だから、これまでのところ私は持っています：

var filteredCepStream = (from window in cepStream.HoppingWindow( TimeSpan.FromMinutes(outputConfig.WindowLength), TimeSpan.FromMinutes(outputConfig.WindowHopSize), HoppingWindowOutputPolicy.ClipToWindowEnd) select window);

しかし、StreamInsight ではウィンドウを送信できません。ユーザー定義の集約を作成する方法や、これをペイロードのリストに変換して出力アダプターに送信する方法はありますか? 私はこれについて間違った方法で進んでいますか？ウィンドウ内のすべてのペイロードを出力アダプターに同時に送信する必要があります。

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

ディナ

StreamInsight のドキュメントを精査すると、「特定のイベント ストリームに対して、イベント A の後にイベント B が続く場合に出力を生成する」という形式のクエリを表現できるはずですが、これを次のように表現する方法がわかりません。 LINQ クエリも、ドキュメントで例を見つけることもできません。

誰でも助けることができますか？事前にThx。

ip:port を指定して、ネットワークからイベントを取得する StreamInsight アプリに入力アダプターを実装したいと考えています (詳細はこちら: http://social.technet.microsoft.com/Forums/en-US/streaminsight/thread/ e7bcc2c4-45b8-4225-836a-102fd3be437b )。私が読んだサンプルはすべてプル方式で動作しますが、私のシナリオではプッシュ方式が必要です。そのようなサンプルを知っていますか？または、何か提案をいただけますか？ネットワーク プログラミングは私の分野ではありませんが、どこから始めればよいかを知っていれば、すぐに学ぶことができます。

ありがとう

StreamInsight をインストールし、サンプルの例を実行できます。しかし、StreamInsight EVENT Flow Debugger を開いて "サーバーに接続" しようとすると、次のエラーが表示されます。

「StreamInsightInstance」という名前のインスタンスを作成し、このリンクを使用してサーバーに接続しました。

誰でも答えを提案できますか？

私は最近CEPを学び始めました。これらのStreamInsighCEPをプロジェクトに実装することを計画しています

私のアプリケーションは次のようなものです：新しく挿入された行をテーブルで監視するアプリケーションを作成する必要があります。これらの新しい行に対して操作を実行する必要があります。

SQL依存関係を使用せずにこれを達成できますか？またはSqlDependecy+CEPを使用できますか。

最適な解決策で私を提案してください