SQL AzureでのLINQ-TO-SQLのリトライロジック - 効率的な実装ですか？

Question

Azureで実行されているLINQ-TO-SQLを使用するかなり大きなWebアプリケーションがあり、SQL-Azureからの一時的なエラーが発生しているため、再試行を実装する必要があります。私はそれを使用する方法の例を与えるTransient Fault Handling Frameworkし、いくつかのサイトを認識してんだけど、あなたはこれに似たもので、あなたのLINQクエリの一つ一つをラップする必要があるように見えます：LINQクエリの何百もの

RetryPolicy retry = new RetryPolicy<MyRetryStrategy>(5, TimeSpan.FromSeconds(5)); 
Result = retry.ExecuteAction(() => 
{ 
    … LINQ query here... 
}); 

私のデータレイヤーでは、これは本当に面倒です。さらに、結果が列挙されるまで多くの時間クエリが実際には実行されないという事実があります。たとえば、データレイヤのほとんどの関数は、リストを返すよりも柔軟性のあるビジネスレイヤまで、IQueryable <を返します。つまり、データベースの再試行ロジックでビジネスロジックレイヤーを浪費しなければならないということです。

データレイヤーでリトライロジックを維持するために、私はすべてのクエリに.ToList（）を配置して、上記のレイヤーではなく、正しく実行されるようにする必要があります。

基本クラスにリトライロジックを実装し、すべてのクエリを変更する必要はないと思います。 EFのように思えますが、この問題もあります。

SQL-Azureチームに自動再試行を試して話す本当の答えは、私たちのコードでは心配する必要はありませんか？

Answer 1

LINQ to SQLではクエリをインターセプトできないため、良い解決策はわかりません。しかし、少しのコードリファクタが役に立ちます。サムシング（擬似コード）のような：

public Result QueryWithRetry(IQueryable query) 
{ 
     RetryPolicy retry = new RetryPolicy<MyRetryStrategy>(5, TimeSpan.FromSeconds(5)); 
    (() => 
    { 
     return retry.ExecuteAction(query); 
    } 
} 

今では、このメソッドを呼び出すために少し簡単です：

結果= QueryWithRetry（ここでは... LINQクエリを...）。

ただし、コードを変更してすべてのクエリを変更する必要があります。

最高のお礼、

Ming Xu。

Answer 2

このような実装が必要な場合は、先に進んでライブラリhttps://github.com/daveaglick/LinqToSqlRetry（MITはNuGetでライセンス供与されています）を作成しました。

代わりSubmitChangesRetry()を書くことでSubmitChanges()呼び出しを再試行することができます

using(var context = new MyDbContext()) 
{ 
    context.Items.InsertOnSubmit(new Item { Name = "ABC" }); 
    context.SubmitChangesRetry(); 
} 

あなたはまた、Retry()拡張メソッドを使用してクエリを再試行することができます

using(var context = new MyDbContext()) 
{ 
    int count = context.Items.Where(x => x.Name == "ABC").Retry().Count(); 
} 

特定の再試行ロジックがポリシーによって制御可能です。ボンネットの下では、再試行メカニズムは次のようになります。

int retryCount = 0; 
while (true) 
{ 
    try 
    { 
     return func(); 
    } 
    catch (Exception ex) 
    { 
     TimeSpan? interval = retryPolicy.ShouldRetry(retryCount, ex); 
     if (!interval.HasValue) 
     { 
      throw; 
     } 
     Thread.Sleep(interval.Value); 
    } 
    retryCount++; 
} 

はfunc()への呼び出しとretryPolicyオブジェクト内の関数は、使用状況に基づいて提供されていることを理解します。これは、リトライループ中に何が起こっているかをあなたに知らせるだけです。詳細については、リポジトリを参照してください。