mongodb.py 文件源码

def insert_proxy(self, table_name, proxy):
        data = proxy.get_dict()
        data['save_time'] = str(time.time())
        data['create_time'] = str(datetime.datetime.now())
        self.db[table_name].create_index([("ip", pymongo.DESCENDING)], unique=True)
        try:
            self.db[table_name].insert(data)
        except BaseException,e:
            if "E11000 duplicate key error collection" in e.message:
                utils.log(str(e.message.split(' ')[12])+"????????")