module_clients.py

from gearsclient import GearsRemoteBuilder as GearsBuilder
from redistimeseries.client import Client

def stream_handler(item):
  data = item['value']
  member = json.dumps(
      {'device_id': data['device_id'],
       'transaction_id': data['transaction_id'],
       'ts': data['ts'],
       })
  redis.Redis().zadd(data.get('device_id'), {member: data['ts']})
  Client().incrby(data['fraud_type'], 1)

GearsBuilder(reader='StreamReader', r=redis_conn, requirements=["redis", "redistimeseries"]).foreach(stream_handler).register('data_stream')