Testing ElastiCache redis faiover

redis_reader.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import os

from datetime import datetime
from time import time, sleep

from redis import StrictRedis


client = StrictRedis.from_url(os.environ.get('REDIS_URL'))


while True:
    t = datetime.utcnow().strftime('%H:%M:%S.%f')
    start = time()
    try:
        v = client.get('testing_failover')
        end = time()
        print u'%s: Read value %s in %sms' % (t, v, 1000 * (end - start))
    except Exception as e:
        end = time()
        print u'%s: Got exception %s in %sms' % (t, str(e), 1000 * (end - start))
    sleep(0.5)

redis_writer.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import os
from datetime import datetime
from time import time, sleep

from redis import StrictRedis


client = StrictRedis.from_url(os.environ.get('REDIS_URL'))


while True:
    t = datetime.utcnow().strftime('%H:%M:%S.%f')
    start = time()
    try:
        v = str(time())
        client.set('testing_failover', v)
        end = time()
        print u'%s: Set value %s in %sms' % (t, v, 1000 * (end - start))
    except Exception as e:
        end = time()
        print u'%s: Got exception %s in %sms' % (t, str(e), 1000 * (end - start))
    sleep(0.5)