def store_metrics()

in lib/receiver-lambda/receiver-lambda.py [0:0]

• 8 lines of code
• 1 McCabe index (conditional complexity)

def store_metrics(key_prefix, metrics, start_time):
    pipe = conn.pipeline(True)
    key = '{0}:{1}'.format(key_prefix, metrics['timestamp'])
    pipe.hmset(key, metrics)
    pipe.expire(key, 3600)
    pipe.zadd(key_prefix, {metrics['timestamp']: metrics['timestamp']})
    pipe.zremrangebyscore(key_prefix, 0, start_time - 1)
    pipe.execute()