[原创] python3代理池的搭建（二）

from crawler import Crawler
import sqlite3
import os
ippool='ip.sqlite'
class Getter():
    def __init__(self):
        self.crawler=Crawler()
        if not os.path.exists(ippool):
            self.conn=sqlite3.connect(ippool)
            self.c=self.conn.cursor()
            self.c.execute('''create table ips
            (ip CHAR(50) PRIMARY KEY NOT NULL,
            score INT NOT NULL);''')
            self.conn.commit()
        else:
            self.conn=sqlite3.connect(ippool)
            self.c=self.conn.cursor()
    def run(self):
        print('获取器开始执行')
        for callback_label in range(self.crawler.__CrawlFuncCount__):
            callback=self.crawler.__CrawlFunc__[callback_label]
            proxies=self.crawler.get_proxies(callback)
            for proxy in proxies:
                try:
                    self.c.execute("insert into ips (ip,score) values(?,?)",(proxy,10))
                    self.conn.commit()
                except:
                    self.conn.rollback()
        #self.conn.commit()
        self.conn.close()