def select_metrics()

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

• 12 lines of code
• 2 McCabe index (conditional complexity)

def select_metrics(key_prefix, unique_id, metrics_list, start_time):
    pipe = conn.pipeline(True)
    pipe.zremrangebyscore(key_prefix, 0, start_time - 1)
    destination = 'tmp:{}'.format(unique_id)
    pipe.zunionstore(destination, [key_prefix], aggregate=None)
    pipe.sort(destination, by=key_prefix + ':*->timestamp_loc', get=[
        key_prefix + ':*->' + metric_name
        for metric_name in metrics_list
    ])
    pipe.delete(destination)
    redis_results = pipe.execute()
    return redis_results[len(redis_results) - 2]