multi-threads-check.py 文件源码

def checkValid(item):
    starttime = datetime.datetime.now()
    rst = checkProxy(proxyIP=item.ip_port,protocol="http",timeout=5)
    costtimie = (datetime.datetime.now()-starttime).seconds
    if rst is not None and rst["status"] == "ok":

        proxy = freshProxy(ip_port=item.ip_port,
                           type=item.type,
                           location=rst["rstLocation"].encode("utf-8"),
                           speed=costtimie,
                           source=item.source,
                           rule_id=item.rule_id,
                           lastcheck=datetime.datetime.now()
                           )

        print rst["rstIP"]
        print rst["rstLocation"].encode("utf-8")
        session=loadSession()
        try:
            session.merge(proxy)
            session.commit()
        except MySQLdb.IntegrityError, e:
            print e.message

    else:
        deleteProxy(item)