added connection retry for redis connector class

Author: Girgitt

pjon_python/utils/RedisConn.py

@@ -3,6 +3,8 @@
 from redis import ConnectionError
 import logging
 import jsonpickle
+from retrying import retry
+
 log = logging.getLogger("redis-conn")
 
 
@@ -41,6 +43,7 @@ def listen(self, rcv_timeout=0.01):
                         return message['data']
         return None
 
+    @retry(wait_fixed=1000, stop_max_attempt_number=3)
     def publish(self, payload, channel=None):
         if channel is None:
             channel = self._pub_channel_name
@@ -51,26 +54,34 @@ def publish(self, payload, channel=None):
             pass
         self._redis_conn.publish(channel, payload)
 
+    @retry(wait_fixed=1000, stop_max_attempt_number=3)
     def hgetall(self, *args, **kwargs):
         return self._redis_conn.hgetall(*args, **kwargs)
 
+    @retry(wait_fixed=1000, stop_max_attempt_number=3)
     def hget(self, *args, **kwargs):
         return self._redis_conn.hget(*args, **kwargs)
 
+    @retry(wait_fixed=1000, stop_max_attempt_number=3)
     def hmset(self, *args, **kwargs):
         return self._redis_conn.hmset(*args, **kwargs)
 
+    @retry(wait_fixed=1000, stop_max_attempt_number=3)
     def delete(self, *args, **kwargs):
         return self._redis_conn.delete(*args, **kwargs)
 
+    @retry(wait_fixed=1000, stop_max_attempt_number=3)
     def hdel(self, *args, **kwargs):
         return self._redis_conn.hdel(*args, **kwargs)
 
+    @retry(wait_fixed=1000, stop_max_attempt_number=3)
     def hset(self, *args, **kwargs):
         return self._redis_conn.hset(*args, **kwargs)
 
+    @retry(wait_fixed=1000, stop_max_attempt_number=3)
     def set(self, *args, **kwargs):
         return self._redis_conn.set(*args, **kwargs)
 
+    @retry(wait_fixed=1000, stop_max_attempt_number=3)
     def get(self, *args, **kwargs):
         return self._redis_conn.get(*args, **kwargs)

requirements.txt

@@ -1,3 +1,4 @@
 mock
 nose
-pyserial >= 3.1.1
+pyserial >= 3.1.1
+retrying