pybreaker_circuit_breaker_decorator_with_failure_threshold.py

1import pybreaker
2import redis
3
4# Create a circuit breaker with a fail_max of 5 and a reset_timeout of 60 seconds
5db_breaker = pybreaker.CircuitBreaker(
6    fail_max=5,
7    reset_timeout=60)
8
9@db_breaker
10def update_customer(cust):
11    # Do something with the database...
12    pass
13
14# Alternatively, you can use the circuit breaker to wrap calls
15try:
16    db_breaker.call(update_customer, my_customer)
17except pybreaker.CircuitOpenError:
18    # The circuit is open, so we can't call the function
19    pass