問題タブ [streaminsight]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票する
1 に答える
122 参照

c# - イベントがない場合、TumblingWindow は起動しますか?

イベントがない場合、StreamInsight TumblingWindow は起動しますか?

ここで見たすべての例では、常に各ウィンドウ内にイベントがあります。 aspx

しかし問題は、特定のウィンドウにイベントがない場合、イベントが発生するかどうかです。

0 投票する
0 に答える
288 参照

wcf - 回復力のある StreamInsight Wcf サンプル

StreamInsight (v2.1!) のことを知り、StreamInsight チームの WCF サンプルに基づくアプリケーションの作業を開始しました。今、そのアプリケーションに回復力と監視を追加したいと思っていますが、その方法がわかりません。Checkpointing Sample とこれらのチュートリアルに従ってみましたが、うまくいきませんでした: http://msdn.microsoft.com/en-us/library/hh290476(v=sql.111).aspx

http://msdn.microsoft.com/en-us/library/ee391166(v=sql.111).aspx

WcfObservable を適応させる必要がありますか? または、オブザーバブル、オブザーバー、およびクエリに回復力を追加するにはどうすればよいですか?

これは私のコードの一部です:

お時間をいただきありがとうございます。

0 投票する
2 に答える
352 参照

linq - HoppingWindowのフィルターを使用したStreamInsightの複雑なクエリ

StreamInsightを試していますが、必要なクエリで問題が発生しました。

過去30分間に測定値にいくつかの変化(最大20%の変化)がある場合、警告をスローしようとしています。

これは私が今思いついたクエリですが、機能しておらず、正しくないと思います。

どうやら私はウィンドウでフィルタリングすることはできません...?

前もって感謝します!

0 投票する
1 に答える
220 参照

c# - 多くのクエリ間でInputAdapterを共有する

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

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

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

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

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

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

0 投票する
1 に答える
501 参照

linq - オブザーバーへの StreamInsight 2.1 アダプター

StreamInsightを BizTalk に接続するために、次のアダプターを実装しようとしています。 アダプター/#comment-11635

最後に、彼は次のようにしてクエリをアダプターにバインドします。

さて、私が間違っていなければ、これは StreamInsight 2.1 では機能しなくなりました。これを行う方法がわかりません。誰でもこれで私を助けることができますか? 前もって感謝します!

0 投票する
3 に答える
734 参照

c# - StreamInsight のパフォーマンスの問題

StreamInsight 2.1 を使用していますが、予期しないパフォーマンスの問題が発生しています。

私は、1 秒あたり 5,000 から 10,000 のイベントで入ってくる財務データの入力アダプターを 1 つ持っています。次に、その入力に対して多数のクエリを実行します。各クエリはまったく同じパススルー クエリに接続されるため、まったく同じ入力データを使用するクエリが 1000 あります。

システムがこれを処理できるかどうかをテストするために、イベントをリリースするだけの出力アダプターにイベントをパススルー ( d in fullStream select d から) するだけの 1000 個のクエリを作成しました。

この方法で 1,000 件のクエリを実行すると、システムがストリームについていけなくなります。それはますます後ろに落ちます。これを 100 クエリにトリミングすると、システムは完全に維持されます。

StreamInsight でパフォーマンスの壁にぶつかっただけですか? 私が構築しているタイプのソリューションを処理できませんか? それとも、私はここで何かばかげたことをしていますか....何か助けがあれば、それを速くするために他に何ができるかわからないでしょう。1000 を超えるクエリを実行できるようにする必要があり、これよりもはるかに複雑なクエリを実行する必要があります。

0 投票する
1 に答える
398 参照

sql - Windows / SQL StreamInsight / テーブルからホッピングしますか?

これは StreamInsight がなくてもできるかもしれませんが、興味があります。

テーブルに「メッセージ」を入力するアプリケーションがあります (テーブルに行を挿入します)。

メッセージが「到着」する速度と、メッセージが「処理」される速度 (フラグが更新される) について、このテーブルを監視する監視アプリケーションを作成したいと考えています。

これはベンダーのアプリケーションであるため、トリガーなどをドロップしたくありません。しかし、データベースにクエリを実行でき、テーブルには ID 列を使用して PK があります。

ホッピング ウィンドウ クエリを取得するにはどうすればよいですか? 過去 30 分間のメッセージ受信率とメッセージ処理率を示す折れ線グラフを表示したいと思います。

0 投票する
0 に答える
147 参照

c#-4.0 - StreamInSight で変更を追跡する方法は?

私のプロジェクトでは、データベース テーブルに新しく挿入された行を追跡する必要があります。そして、それらの行を処理のために .net アプリケーションに渡します。私は StremInSight を調べましたが、正しく適合しています。それ以外の場合は、ServiceBroker と StremInSight の両方をクラブにするにはどうすればよいでしょうか。つまり、サービス ブローカーを使用して変更を StreamInsight にストリーミングできますか?

0 投票する
2 に答える
334 参照

azure - StreamInsightAustinサンプルサービスバス404

オースティンサンプルをベースにしたサンプルアプリケーションを作成しようとしています。最初にサンプルで404を入手し、App.ConfigでconnectionStringを調整して修正しました(これを忘れてしまいました。悪いです)。これで、AzureテーブルではなくServiceBusキューにメッセージを送信する2番目のシンクを作成しました。SampleApplicationとEventSourceSimulatorを起動すると、最初の2つのメッセージは正しく通過したように見えますが、3番目のメッセージは404エラーを示しています。以下は、エラーと私のシンクのクラスのスクリーンショットです。私を助けるためにもっと情報が必要な場合は、教えてください。前もって感謝します、

オースティン404エラー

更新:管理ポータルのService Busキューに何も表示されないため、何も表示されないと思います。

0 投票する
1 に答える
114 参照

c# - StreamInsight2.0での例外処理

StreamInsight 2.0で例外を処理するためのベストプラクティスは何ですか?

例外が発生した場合(イベントの欠落については話していませんが、コード内のNullReferenceExceptionのような実際の例外については)、すべてが非同期で実行されることを考慮して、どのように処理し、アプリケーションを安全に停止しますか?