How can I catch an 'Exception' from 'CircuitBreaker' to generate a log?

Question

How can I catch an 'Exception' from 'CircuitBreaker' to generate a log?

Navigation

#1 by (0 votes)

0

I'm trying to capture through Action onBreak, but apparently it never throws the exception on the screen.

using Polly;
using System;
using System.Collections.Generic;

namespace CircuitBreakingPolly
{
    public class Program
    {
        public static int n1 = 2;
        public static int n2 = 0;

        private static List<Produtos> produtos = new List<Produtos>();
        static void Main(string[] args)
        {
            var result = Execute(() => Divisao(n1, n2), () => Divisao(2, 2));
            Console.WriteLine(result.ToString());

            Console.ReadKey();
        }

        public static TResult Execute<TResult, TReset>(Func<TResult> action, Func<TReset> actionReset)
        {

            return Policy
                .Handle<DivideByZeroException>()
                .CircuitBreaker(4, TimeSpan.FromMinutes(1), onBreak: (exception, timespan, context) =>
                {
                    Console.Write(exception.Message, timespan);
                }
                , onReset: (context) =>
                {
                    actionReset.Invoke();
                }
                , onHalfOpen: () =>
                {
                    actionReset.Invoke();
                })
                .Execute(action);
        }


        private static int Divisao(int n1, int n2)
        {
            return n1 / n2;
        }


        internal static void AtualizarNumero(Exception e, int n)
        {
            n2 = n;
            PoliticasManipulacaoPolly.Log(e);
        }
    }
}

c# circuitbreaking polly

asked by anonymous 12.07.2017 / 20:29

1 answer

Error in Django - Unicode Decode Error How to apply hover effect to an element immediately before?

score 0 · Accepted Answer

I discovered that CircuitBreaker does not work by itself, it needs to be combined with another policy like Retry.

In my case it was like this.

public Task ExecuteCircuitBreaker(Func<Task> action)
        {
            //Program.programStartTime = DateTime.Now;
            // simular o erro
            Program.programStartTime = DateTime.Now.AddSeconds(10);

            int totalvezes = 2;
            Task result2 = null;

            //Thread safety
            //PolicyWrap is thread - safe: multiple calls may safely be placed concurrently through a policy instance.
            //Policy reuse
            //PolicyWrap instances may be re - used across multiple call sites.
            //When reusing policies, use an ExecutionKey to distinguish different call - site usages within logging and metrics.

            Policy retryPolicy = Policy.Handle<TimeoutException>().RetryAsync(totalvezes);

            Policy circuitBreakerPolicy = Policy
                .Handle<TimeoutException>()
                .CircuitBreakerAsync(totalvezes, TimeSpan.FromSeconds(2));

            try
            {
                // you need to combine retry policy with circuit breaker policy. One way to do that would be:
                result2 = retryPolicy.ExecuteAsync(() => circuitBreakerPolicy.ExecuteAsync(action, true));

                // or Polly has also now added PolicyWrap which can make the syntax for
                //combining policies even more concise:

                //result2 = retryPolicy.WrapAsync(circuitBreakerPolicy).ExecuteAsync(action, true);
            }
            catch (AggregateException ex)
            {
                Log(ex);
            }
            catch (Exception ex)
            {
                Log(ex);
            }

            return result2;
        }