Быстрое получение популярных записей со страниц VK

def parse_args():
    """ Parses input arguments """
    parser = argparse.ArgumentParser()
    parser.add_argument('url',
                        action='store',
                        default=None,
                        help='target page',
                        type=url_validator)
    compar_key = parser.add_mutually_exclusive_group()
    compar_key.add_argument('-l',
                            '--likes',
                            help='sort posts by likes',
                            action='store_true',
                            default=True)
    compar_key.add_argument('-r',
                            '--reposts',
                            help='sort posts by reposts',
                            action='store_true')

    parser.add_argument('-t',
                        '--top',
                        help='number of showing posts.',
                        default=10,
                        type=num_validator)

    parser.add_argument('-d',
                        '--days',
                        type=int,
                        default=-1,
                        help='period for post processing.')
    return parser.parse_args()

def url_validator(arg):
    """ Checks correctness of url argument """
    arg = arg.lower()

    # If url something like https://vk.com/textual_id
    matched_txt_id = const.TXT_ID_REGEXP.match(arg)
    if matched_txt_id:
        url = matched_txt_id.groupdict()
        url['type'] = 'symbolic'
        return url

    # If url something like https://vk.com/id123456
    matched_numeric_id = const.NUM_ID_REGEXP.match(arg)
    if matched_numeric_id:
        return matched_numeric_id.groupdict()

    raise argparse.ArgumentTypeError(
            const.INVALID_URL.format(url=arg))

def get_page_id(url):
    """ Returns page's numeric ID """
    if url['type'] not in ['id', 'public', 'event', 'club']:
        params = {'screen_name': url['id']}
        request = requests.get(const.API_URL + 'utils.resolveScreenName?',
                               params=params)
        response = json.loads(request.text)['response']

        if response:
            if response['type'] == 'user':
                return response['object_id']
            else:
                # Groups have negative id
                return -response['object_id']
        else:
            raise PageNotAvailable(url['id'] + ' is not available')
    
    if url['type'] == 'id':
        return int(url['id'])
    else:
        return -int(url['id'])

def recieve_posts(page_id):
    """
    Returns :received_posts: from :page_id:
    """
    params = {'access_token': const.ACCESS_TOKEN,
              'id': page_id,
              }
    received_posts = []

    offset = 0
    while True:
        params['offset'] = offset
        response = json.loads(requests.post(
            const.API_URL + 'execute.getPosts?', params=params).text)

        # Interrupt loop when all posts were received
        if not response['response']:
            break

        received_data = response['response']
        for chunk in received_data:
            for post in chunk:
                received_posts.append(post)
        offset += 1

    return received_posts

// количество итераций цикла\запросов к API
var ITERS = 25;
// количество сообщений получаемых за один запрос
var COUNT = 100;
// список полученных постов
var posts = []; 
var req_params = {
        "owner_id" : Args.id, // id страницы
        "offset" : 0,         // смещение
        "count"  : COUNT,
        "v" : "5.34"          // версия API
};
var i = 0;
while(i < ITERS) {
    req_params.offset = i*COUNT + ITERS*COUNT*Args.offset;
    // Делаем запрос к API
    var items = API.wall.get(req_params).items; 
    // Пустой список означает, что все записи получены
    if (items.length == 0) {
        return posts;
    }
    // Добавляем промежуточный результат
    // в итоговый список
    posts.push(items); 
    i = i + 1;
}
return posts;

// количество итераций цикла\запросов к API
var ITERS = 25;
// количество сообщений получаемых за один запрос
var COUNT = 100;
// список полученных постов
var posts = []; 
var req_params = {
        "owner_id" : Args.id, // id страницы
        "offset" : 0,         // смещение
        "count"  : COUNT,
        "v" : "5.34"          // версия API
};
var i = 0;
while(i < ITERS) {
    req_params.offset = i*COUNT + ITERS*COUNT*Args.offset;
    // Делаем запрос к API
    var items = API.wall.get(req_params).items; 
    // Пустой список означает, что все записи получены
    if (items.length == 0) {
        return posts;
    }
    
    // Для хранения промежуточных ответов
    var tmp = {};
    // Фильтр. Получем список из id постов
    tmp.ids = items@.id;
    // Фильтр. Получем список из дат, публикаций постов
    tmp.dates = items@.date;
    // Так же, в execute передается доп. параметр Args.compar_key,
    // В зависимости от которого, добавляется нужный список.
    if (Args.compar_key == "likes") {
        tmp.likes = items@.likes@.count;
    } else {
        tmp.reposts = items@.reposts@.count;
    }
    posts.push(tmp);

    i = i + 1;
}
return posts;

// количество итераций цикла\запросов к API
var ITERS = 25;
// количество сообщений получаемых за один запрос
var COUNT = 100;
// список полученных постов
var posts = []; 
var req_params = {
        "owner_id" : Args.id, // id страницы
        "offset" : 0,         // смещение
        "count"  : COUNT,
        "v" : "5.34"          // версия API
};
var i = 0;
while(i < ITERS) {
    req_params.offset = i*COUNT + ITERS*COUNT*Args.offset;
    // Делаем запрос к API
    var items = API.wall.get(req_params).items; 
    // Пустой список означает, что все записи получены
    if (items.length == 0) {
        return posts;
    }
    
    // Для хранения промежуточных ответов
    var tmp = {};
    // Фильтр. Получем список из id постов
    tmp.ids = items@.id;
    // Фильтр. Получем список из дат, публикаций постов
    tmp.dates = items@.date;
    // Так же, в execute передается доп. параметр Args.compar_key,
    // В зависимости от которого, добавляется нужный список.
    if (Args.compar_key == "likes") {
        tmp.likes = items@.likes@.count;
    } else {
        tmp.reposts = items@.reposts@.count;
    }
    // Args.deadline - крайняя дата публикации.
    // Если равна -1, значит нужно получить все посты.
    // Иначе смотрим на дату последнего полученного поста,
    // Если он опубликован раньше deadline, значит дальнейшие
    // Запросы делать не нужно. Вернуть результат.
    if (Args.deadline != -1 && tmp.dates[tmp.dates.length - 1] < Args.deadline) {
        // Флаг, для остановки локального цикла.
        tmp.stop = "True";
        posts.push(tmp);
        return posts;
    } else {
        posts.push(tmp);
    }

    i = i + 1;
}
return posts;

def recieve_posts(page_id, last_days, reposts):
    """
    Returns posts from :page_id: that were posted not earlier
    than :last_days: ago
    """
    deadline = datetime.now() - timedelta(days=last_days)
    unix_stamp = int(deadline.strftime("%s"))

    if reposts:
        compar_key = const.REPOSTS
    else:
        compar_key = const.LIKES

    params = {'access_token': const.ACCESS_TOKEN,
              'id': page_id,
              'compar_key': compar_key,
              'deadline':  unix_stamp if last_days != -1 else last_days
              }
    received_posts = []

    offset = 0
    ONGOING = True
    while ONGOING:
        params['offset'] = offset
        response = json.loads(requests.post(
            const.API_URL + 'execute.getPostsNew?', params=params).text)

        # Interrupt loop when all posts were received
        if not response['response']:
            break

        received_data = response['response']
        for chunk in received_data:
            chunk_size = len(chunk['ids'])
            for i in range(chunk_size):
                post = dict()
                post['date'] = datetime.fromtimestamp(chunk['dates'][i])
                if  last_days == -1
                    or post['date'].year   >= deadline.year
                    and post['date'].month >= deadline.month
                    and post['date'].day   >= deadline.day:

                    post['id'] = chunk['ids'][i]
                    post[compar_key] = chunk[compar_key][i]
                    received_posts.append(post)
            if 'stop' in chunk:
                ONGOING = False
                break
        offset += 1

    return received_posts