問題タブ [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.
c# - イベントがない場合、TumblingWindow は起動しますか?
イベントがない場合、StreamInsight TumblingWindow は起動しますか?
ここで見たすべての例では、常に各ウィンドウ内にイベントがあります。 aspx
しかし問題は、特定のウィンドウにイベントがない場合、イベントが発生するかどうかです。
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 を適応させる必要がありますか? または、オブザーバブル、オブザーバー、およびクエリに回復力を追加するにはどうすればよいですか?
これは私のコードの一部です:
お時間をいただきありがとうございます。
linq - HoppingWindowのフィルターを使用したStreamInsightの複雑なクエリ
StreamInsightを試していますが、必要なクエリで問題が発生しました。
過去30分間に測定値にいくつかの変化(最大20%の変化)がある場合、警告をスローしようとしています。
これは私が今思いついたクエリですが、機能しておらず、正しくないと思います。
どうやら私はウィンドウでフィルタリングすることはできません...?
前もって感謝します!
c# - 多くのクエリ間でInputAdapterを共有する
StreamInsight2.1を使用してStreamInsightアプリケーションに取り組んでいます。
入力アダプターは、1秒あたり数千のイベントを含むライブストックデータストリームになります。同じデータストリームを使用して複数の独立したクエリを実行し、ストリームの実行中にさらにクエリを追加して、ストリーム内の現在の場所で取得できるようにしたい。
ただし、クエリを作成するたびに、まったく新しい入力アダプタが作成されます。したがって、25個の入力アダプターがすべて同じデータをロードおよびプッシュすることになります。
私はこれを間違って考えているだけですか?入力アダプタは各クエリから独立していますか?
ライブストックデータを入力アダプターの背後に置き、各入力アダプターにそのデータを再度ストリーミングさせる唯一のソリューションはありますか?
どんなアドバイスも素晴らしいでしょう、StreamInsightに関する良いドキュメントを見つけるのは難しいです。
linq - オブザーバーへの StreamInsight 2.1 アダプター
StreamInsightを BizTalk に接続するために、次のアダプターを実装しようとしています。 アダプター/#comment-11635
最後に、彼は次のようにしてクエリをアダプターにバインドします。
さて、私が間違っていなければ、これは StreamInsight 2.1 では機能しなくなりました。これを行う方法がわかりません。誰でもこれで私を助けることができますか? 前もって感謝します!
c# - StreamInsight のパフォーマンスの問題
StreamInsight 2.1 を使用していますが、予期しないパフォーマンスの問題が発生しています。
私は、1 秒あたり 5,000 から 10,000 のイベントで入ってくる財務データの入力アダプターを 1 つ持っています。次に、その入力に対して多数のクエリを実行します。各クエリはまったく同じパススルー クエリに接続されるため、まったく同じ入力データを使用するクエリが 1000 あります。
システムがこれを処理できるかどうかをテストするために、イベントをリリースするだけの出力アダプターにイベントをパススルー ( d in fullStream select d から) するだけの 1000 個のクエリを作成しました。
この方法で 1,000 件のクエリを実行すると、システムがストリームについていけなくなります。それはますます後ろに落ちます。これを 100 クエリにトリミングすると、システムは完全に維持されます。
StreamInsight でパフォーマンスの壁にぶつかっただけですか? 私が構築しているタイプのソリューションを処理できませんか? それとも、私はここで何かばかげたことをしていますか....何か助けがあれば、それを速くするために他に何ができるかわからないでしょう。1000 を超えるクエリを実行できるようにする必要があり、これよりもはるかに複雑なクエリを実行する必要があります。
sql - Windows / SQL StreamInsight / テーブルからホッピングしますか?
これは StreamInsight がなくてもできるかもしれませんが、興味があります。
テーブルに「メッセージ」を入力するアプリケーションがあります (テーブルに行を挿入します)。
メッセージが「到着」する速度と、メッセージが「処理」される速度 (フラグが更新される) について、このテーブルを監視する監視アプリケーションを作成したいと考えています。
これはベンダーのアプリケーションであるため、トリガーなどをドロップしたくありません。しかし、データベースにクエリを実行でき、テーブルには ID 列を使用して PK があります。
ホッピング ウィンドウ クエリを取得するにはどうすればよいですか? 過去 30 分間のメッセージ受信率とメッセージ処理率を示す折れ線グラフを表示したいと思います。
c#-4.0 - StreamInSight で変更を追跡する方法は?
私のプロジェクトでは、データベース テーブルに新しく挿入された行を追跡する必要があります。そして、それらの行を処理のために .net アプリケーションに渡します。私は StremInSight を調べましたが、正しく適合しています。それ以外の場合は、ServiceBroker と StremInSight の両方をクラブにするにはどうすればよいでしょうか。つまり、サービス ブローカーを使用して変更を StreamInsight にストリーミングできますか?
azure - StreamInsightAustinサンプルサービスバス404
オースティンサンプルをベースにしたサンプルアプリケーションを作成しようとしています。最初にサンプルで404を入手し、App.ConfigでconnectionStringを調整して修正しました(これを忘れてしまいました。悪いです)。これで、AzureテーブルではなくServiceBusキューにメッセージを送信する2番目のシンクを作成しました。SampleApplicationとEventSourceSimulatorを起動すると、最初の2つのメッセージは正しく通過したように見えますが、3番目のメッセージは404エラーを示しています。以下は、エラーと私のシンクのクラスのスクリーンショットです。私を助けるためにもっと情報が必要な場合は、教えてください。前もって感謝します、
更新:管理ポータルのService Busキューに何も表示されないため、何も表示されないと思います。
c# - StreamInsight2.0での例外処理
StreamInsight 2.0で例外を処理するためのベストプラクティスは何ですか?
例外が発生した場合(イベントの欠落については話していませんが、コード内のNullReferenceExceptionのような実際の例外については)、すべてが非同期で実行されることを考慮して、どのように処理し、アプリケーションを安全に停止しますか?