def clean_with_video_id(id):
    r = redis.StrictRedis(host=REDIS_ADDR, port=REDIS_PORT, db=REDIS_DB)
    for keybatch in batcher(r.scan_iter('*'), 500):
        for i in keybatch:
            if i:
                if (json.loads(r.get(i)).get('videoId') == id):
                    r.delete(i)
def clean_with_video_id(id):
    r = redis.StrictRedis(host=REDIS_ADDR, port=REDIS_PORT, db=REDIS_DB)
    for keybatch in batcher(r.scan_iter('*'), 500):
        for i in keybatch:
            if i:
                if (json.loads(r.get(i)).get('videoId') == id):
                    r.delete(i)