基于Python实现船舶的MMSI的获取(推荐)

import requestsimport osimport timeimport pymysqlimport pandas as pdimport re'''author:shikailiangfunction:通过读取船舶数据，分别请求拿到json数据入库'''#定义入库的类class company_ship_in_database:  def __init__(self):    self.conn = pymysql.connect(host="192.168.1.222", user="root", password="Cjh#Sjzx@", database="test", charset="utf8")    self.cursor = self.conn.cursor()    #获取当前文件的父级地址    self.last_path = os.path.abspath(os.path.dirname(os.getcwd()))  #写入mysql  def in_database(self,data_list):  	#j用来对数据进行计数    j=1    #定义sql    sql = ""    #定义sql头    sql0 = "insert into bms_company_ship_test(oc_name,ship_name,mmsi) values"    rowcount=len(data_list)    for i in data_list:    	#定义拼接sql      sql2 = (("(" + "'{}'," * 3)[:-1] + ")").format(i[1][0],i[1][1],i[0])      sql = sql + "," + sql2      # print(sql0 + sql[1:])      if divmod(j, 300)[1] == 0 or j == rowcount:        #如果执行错误回滚当前事务        # print(sql0 + sql[1:])        try:          self.cursor.execute(sql0 + sql[1:])        except:        	#执行错误，回滚事务          self.conn.rollback()          continue        sql= ""      self.conn.commit()      j=j+1  #通过pandas写入excel  def in_xls(self, data_list):    df=pd.DataFrame(data_list)    #通过pandas实现存为excel    df.to_excel(self.last_path + r"/data/result.xls",header=False,index=False)  #请求船的方法  def company_ship_in_database(self):    data_path = self.last_path + r"/data"    file=open(data_path + "/company.txt")    data=[]    j = 0    for i in file.readlines():    	#将船公司和船舶名称分开      chuan=i.strip().split()      dic={      'f':'auto',      'kw':chuan[1]      }      rq=requests.get("http://searchv3.shipxy.com/shipdata/search3.ashx",params=dic)      #判断是否请求成功      if rq.status_code==200:        try:          result_json=rq.json()          result=result_json['ship'][0]          #判断船舶数字部分是否相同          if re.search('/d+',result['n']).group()==re.search('/d+',chuan[1]).group():            result=result['m']            data.append([result,chuan])          else:            data.append(["", chuan])        except:          data.append(["",chuan])      else:        print(chuan + "请求错误")      time.sleep(0.5)      j = j + 1      if divmod(j,100)[1] == 0:        print("已经请求" + str(j) + "条")      # if j > 10:      #  self.in_xls(data)        # break    self.in_database(data)if __name__=="__main__":  company_ship=company_ship_in_database()  company_ship.company_ship_in_database()