4

新しいエンティティをテーブルに挿入するために、マイクロソフトの標準的な例を使用しています。再試行が実行されたかどうかを追跡する方法はありますか?

コード：

CloudTableClient tableClient = storageAccount.CreateCloudTableClient();
CloudTable table = tableClient.GetTableReference("people");
CustomerEntity customer1 = new CustomerEntity("Harp", "Walter");
TableOperation insertOperation = TableOperation.Insert(customer1);
table.Execute(insertOperation);

TransientFaultHandlingFramework を使用すると、簡単に実行できます。

var retryPol = new RetryPolicy<SqlAzureTransientErrorDetectionStrategy>(retryStrategy); 
retryPol.Retrying += (obj, eventArgs) =>
{
var msg = String.Format("Retrying, CurrentRetryCount = {0} , Delay = {1}, Exception = {2}", eventArgs.CurrentRetryCount, eventArgs.Delay, eventArgs.LastException.Message);
System.Diagnostics.Debug.WriteLine(msg);
};
4

2 に答える 2

5

Rob's answerで説明されているように、 Enterprise Library Transient Fault Handling Application Blockを使用できます。

var retryPol = new RetryPolicy<StorageTransientErrorDetectionStrategy>(retryStrategy); 
retryPol.Retrying += (obj, eventArgs) =>
{
    var msg = String.Format("Retrying, CurrentRetryCount = {0} , Delay = {1}, Exception = {2}", eventArgs.CurrentRetryCount, eventArgs.Delay, eventArgs.LastException.Message);
    System.Diagnostics.Debug.WriteLine(msg);
};

var options = new TableRequestOptions { RetryPolicy = new RetryPolicies.NoRetry() };

CloudTableClient tableClient = storageAccount.CreateCloudTableClient();
CloudTable table = tableClient.GetTableReference("people");
CustomerEntity customer1 = new CustomerEntity("Harp", "Walter");
TableOperation insertOperation = TableOperation.Insert(customer1);

retryPol.ExecuteAction<TableResult>(() => { return table.Execute(insertOperation, options); });

Windows Azure ストレージ クライアント ライブラリのみを使用する場合は、次のように、イベントを発生させるカスタム再試行ポリシーを作成できます。

public class EventExponentialRetry : IRetryPolicy
{
    private static readonly TimeSpan DefaultClientBackoff = TimeSpan.FromSeconds(4.0);
    private const int DefaultClientRetryCount = 3;
    private TimeSpan deltaBackoff;
    private int maximumAttempts;
    private ExponentialRetry retry;

    public event EventHandler<RetryEventArgs> RaiseRetryEvent;

    public EventExponentialRetry()
    {
        Initialize(DefaultClientBackoff, DefaultClientRetryCount);
    }

    public EventExponentialRetry(TimeSpan deltaBackoff, int maxAttempts)
    {
        Initialize(deltaBackoff, maxAttempts);
    }

    private void Initialize(TimeSpan deltaBackoff, int maxAttempts)
    {
        this.deltaBackoff = deltaBackoff;
        this.maximumAttempts = maxAttempts;
        retry = new ExponentialRetry(this.deltaBackoff, this.maximumAttempts);
    }

    public IRetryPolicy CreateInstance()
    {
        EventExponentialRetry newInstance = new EventExponentialRetry(this.deltaBackoff, this.maximumAttempts);
        newInstance.RaiseRetryEvent = this.RaiseRetryEvent;
        return newInstance;
    }

    public bool ShouldRetry(int currentRetryCount, int statusCode, Exception lastException, out TimeSpan retryInterval, OperationContext operationContext)
    {
        bool shouldRetry = retry.ShouldRetry(currentRetryCount, statusCode, lastException, out retryInterval, operationContext);
        if (shouldRetry)
        {
            OnRaiseRetryEvent(new RetryEventArgs(currentRetryCount, statusCode, lastException, retryInterval, operationContext));
        }
        return shouldRetry;
    }

    protected virtual void OnRaiseRetryEvent(RetryEventArgs e)
    {
        // Make a temporary copy of the event to avoid possibility of 
        // a race condition if the last subscriber unsubscribes 
        // immediately after the null check and before the event is raised.
        EventHandler<RetryEventArgs> handler = RaiseRetryEvent;

        // Event will be null if there are no subscribers.
        if (handler != null)
        {
            // Use the () operator to raise the event.
            handler(this, e);
        }
    }
}

完全なサンプルについては、 CustomAzureStorageRetryPolicySample GitHub プロジェクトを参照してください。

于 2013-07-04T18:21:09.343 に答える