問題タブ [streaminsight]

テーブルを監視するために、sqlDependency を使用して StreamInsight 入力アダプターを作成する必要があります。実際に SqlDependency を使用すると、テーブルに挿入された新しい行について通知できます。そのため、Streaminsight 複合イベント処理を使用してこれらを実装する予定です。したがって、これらを入力アダプターに実装する方法を誰でも助けることができます。

つまり、InputAdapter の ProduceEvents() 関数では、変更のためにテーブルに対してクエリを継続的に実行する必要がありますか? または、入力アダプターで sqldependency を使用できますか? もしそうなら、これらを使用する方法。

ありがとう、サンディ

IObservable/IObserver Model を使用して streamInsight アプリケーションを実装するのを手伝ってくれる人はいますか? これらを実装するのに十分なソースがありません。これらのトピックに関する有用なリンクは高く評価されています。

前もって感謝します。

Event Flow Debuggerツールを使用して（Windowsサービスバージョンではなく）Visual Studioで実行されているインプロセスStreamInsightホストに接続しようとしましたが、失敗しました。

誰かがこれを経験したことがありますか？私は次のブログ投稿を見ています：

エンドツーエンドのStreamInsightの例： http： //blogs.msdn.com/b/masimms/archive/2010/08/10/building-your-first-end-to-end-streaminsight-application.aspx

インプロセスとスタンドアロンホストの展開モデル：http ：//seroter.wordpress.com/2010/06/27/leveraging-and-managing-the-streaminsight-standalone-host/

いくつかの変数の値を含むイベントストリームがあります。値は毎秒変化します。各変数には、上限、下限、およびしきい値期間が定義されています。

たとえば、Variable1の上限= 95、下限= 5、しきい値=5秒であるとします。

したがって、Variable1の値がしきい値期間（5秒）の間95（上限）を超えたままである場合は、出力イベントを作成する必要があります。

個々のイベントをチェックするためのクエリを作成することはできますが（制限を超えている場合）、しきい値期間中に制限に違反していないかどうかを確認するためのウィンドウクエリを作成する方法がわかりません。

ありがとう、

StreamInsightを現在(デモ以外で)使用している人はいますか? もしそうなら、それはあなたの環境で現在どのように機能していますか? 私たちは現在、それを実装する可能性を検討していますが、それについて、またはそれが本当に実行可能なオプションであるかどうかについては、誰も知りません.

価格の見積もりが見つからず、ダウンロードだけです (最新バージョンは 1.2 のようです)。

ヒント/提案/コメントは大歓迎です。現在、.Net と SQL Server を使用しているため、当社の環境に適していると思われます。

誰かがこれの良い実装を知っていますか？

CEPを実行したいのですが、StreamInsightを使用すると、控えめに言うと多少コストがかかります。ライセンス費用だけでもかなり負担がかかります。任意のODBCデータベースにプラグインしたり、ディスクに書き込んだりできるQbservableの代替を実装するリアクティブフレームワークはありますか？

ストリームインサイトのユーザー定義関数の制限は何ですか？

オブジェクトはシリアル化可能である必要がありますか？

外部（リモート）サービスを呼び出すことはできますか？

もしそうなら、これらは非常に-非常に-非常に強力に見えます！

ペイロード、つまりStockTicksData idに基づいて最新のイベントを検討し、時間枠内の重複を無視したい

ペイロードとクエリ

上記のクエリは正常に機能しますが、入力アダプタを使用する場合は、出力をフラッシュするためにctiイベントを挿入する必要があります。これがコードです

ダニジェネレーター それは到着の時間を持っています

priceTick.TimeofArrival = DateTime.Now.AddTicks（1）;

入力アダプター

同じクエリでは、入力アダプタとctiイベントで期待される出力が得られません

どんな助けでも大歓迎です。

私は LINQ を初めて使用します。上記のコードは問題なく実行されています。

しかし、最後の文で c.Quantity ではなく c.payload.Quantity と書かれている理由がわかりませんでした。

ググってみたところ、cの結果から取得したペイロードからQuantityという値が得られていることがわかりましたが、それはペイロードがfilterQueryの最終出力ということですか？

終了時刻がわかっている間隔イベントがあるとします。間隔イベントの有効期限が切れる前に、別のイベントを発生させる方法はありますか。これの目的は、その時点で集計を行う必要があることです。

または、クエリを実行する方法はありますか (これは望ましい方法ではありませんが、それに頼る必要があるかもしれません)

私の理解が完全にずれている場合は、より良いアプローチを提案してください。