common.py 文件源码

def insert_db(ipdate):
    lock = threading.Lock()
    try:
        # ???????????????UTF-8???????????
        lock.acquire()
        conn = env.conn
        cur = conn.cursor()  # ????????

        # ????
        ISOTIMEFORMAT = '%Y-%m-%d %X'
        ipdate.append(time.strftime(ISOTIMEFORMAT, time.localtime()))
        log.step_normal( 'ipdate:[%s]' % ipdate)
        cur.execute(
            "INSERT INTO ip_log(ip,address,keyword,url,click,error,page,rank,created_at) VALUES(%s, %s, %s, %s, %s, %s, %s, %s, %s)",
            ipdate)
        cur.close()  # ????
        conn.commit()  # ?????????????????????????????????
        # conn.close()  # ?????????????????
        lock.release()
        log.step_normal('???????')
    except (MySQLdb.OperationalError,Exception) as e:
        log.step_warning('???????:[%s]' % e)