Actualizacion de rucs

rucs.py

import os
import threading
import zipfile

import requests


class DownloadRUC(threading.Thread):
    __index = 0
    __version = 0

    def setIndex(self, i):
        self.__index = i

    def setVersion(self, version):
        self.__version = version

    def __init__(self, group=None, target=None, name=None, args=(), kwargs=None, verbose=None):
        super(DownloadRUC, self).__init__(group, target, name, args, kwargs, verbose)
        print self.getName(), 'ready'

    def run(self):
        print self.getName(), 'run'
        i = self.__index
        version = self.__version
        url = "http://www.set.gov.py/rest/contents/download/collaboration/sites/PARAGUAY-SET/documents/informes-periodicos/ruc/ruc{}.zip"
        # url = "http://www.set.gov.py/rest/contents/download/collaboration/sites/PARAGUAY-SET/documents/informes-periodicos/ruc/ruc{}.zip?version={}?version={}"
        r = requests.get(url.format(i, version), stream=True)
        print self.getName(), r.status_code
        if r.status_code == 200:
            with open('datos/ruc{}.zip'.format(i), 'wb') as f:
                f.write(r.content)
                f.close()
            f = r.headers.get('content-disposition')
            print self.getName(), 'done'
        else:
            print "error de coneccion"
        del r
        f = zipfile.ZipFile('datos/ruc{}.zip'.format(self.__index), 'r')
        f.extractall('datos')
        f.close()


def update(version=14):
    p = []
    for item in xrange(0, 10):
        if not os.path.exists('datos'):
            os.makedirs('datos')
        k = DownloadRUC()
        k.setIndex(item)
        k.setVersion(version)
        p.append(k)
        k.start()


def volvar():
    for i in range(0, 10):
        pass


if __name__ == '__main__':
    update()