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 を適応させる必要がありますか? または、オブザーバブル、オブザーバー、およびクエリに回復力を追加するにはどうすればよいですか?
これは私のコードの一部です:
var wcfIn = app.DefineObservable(() => new WcfObservable(wcfSourceURL));
var wcfStream = wcfIn.ToPointStreamable(i => PointEvent.CreateInsert<Measurement>(i.T, i.M),
AdvanceTimeSettings.IncreasingStartTime);
//Check measurements for deflections
var deflectionQuery = from r in wcfStream
where r.Value > measurableValue * 1 + threshhold || r.Value < measurableValue * 0 + threshhold
select new OutputEvent
{
M = r,
Deflection = (r.Value - measurableValue) / measurableValue,
Error = "Deflection"
};
var sqlObserver = app.DefineObserver(() => Observer.Create<OutputEvent>(SqlWritePoint));
proc = deflectionQuery.Bind(sqlObserver).RunCheckpointable(procName);
お時間をいただきありがとうございます。