redis-py that handles errors better.
Project description
This module wraps the execute_command method of the Redis class, allowing any retry passed to be used. It also introduces a new Backoff, LimitedTimeBackoff, allowing one to set a timeout before which the BackoffTimeoutExceeded is raised.
The purpose of the module is to provide an alternative to the official redis app, as we await an update to hanlding timeout errors.
Usage
Provide a retry to the Redis class which shall be used later.
Examples
import redis
import socket
import redis_exec_retry
max_seconds = 2
backoff_instance = redis.backoff.ExponentialBackoff()
retry = redis.retry.Retry(
backoff=redis_exec_retry.LimitedTimeBackOff(max_seconds, backoff_instance=backoff_instance),
retries=-1,
supported_errors=(
redis.exceptions.BusyLoadingError,
redis.exceptions.ConnectionError,
redis.exceptions.TimeoutError,
socket.timeout,
),
)
r = redis_exec_retry.Redis(port=1000, retry=retry)
print(r.keys("*")) # will run for 2 seconds before raising redis_exec_retry.BackoffTimeoutExceeded
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
redis_exec_retry-0.0.2.tar.gz
(6.4 kB
view hashes)
Built Distribution
Close
Hashes for redis_exec_retry-0.0.2-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | bf185a8a41c48ca999a195551ac4682231a46aec1348fcfcba359d6c8c16b10a |
|
MD5 | 592c4154af05ce92eb0c65597b3d708d |
|
BLAKE2b-256 | 9bf8dc50d5828fdc398014d9c9b2c86f2e64909ae4ec7c0b6a4e752e21e51166 |