从国家统计局获取最新国家省市区的行政区域数据

源代码

import requests
from bs4 import BeautifulSoup
import pymysql
import time

class Administrative(object):
    def __init__(self):
        self.db = pymysql.connect("127.0.0.1","root","a","travel",charset="utf8mb4")#mysql数据库
        self.main()
        self.db.close()

    def main(self):
        base_url='http://www.stats.gov.cn/tjsj/tjbz/tjyqhdmhcxhfdm/2018/'
        trs=self.get_response(base_url,'provincetr')
        for tr in trs:#循环每一行
            datas=[]
            for td in tr:#循环每个省
                province_name=td.a.get_text()
                province_url=base_url+td.a.get('href')
                print(province_name)
                trs=self.get_response(province_url,None)
                for tr in trs[1:]:#循环每个市
                    city_code=tr.find_all('td')[0].string
                    city_name=tr.find_all('td')[1].string
                    city_url=base_url+tr.find_all('td')[1].a.get('href')
                    trs=self.get_response(city_url,None)
                    for tr in trs[1:]:#循环每个区
                        county_code=tr.find_all('td')[0].string
                        county_name=tr.find_all('td')[1].string
                        data=[province_name,city_code,city_name,county_code,county_name]
                        print(data)
                        datas.append(data)
                    time.sleep(1)
            sql="insert into china (province_name,city_code,city_name,county_code,county_name) values (%s,%s,%s,%s,%s)"
            self.connect_mysql(sql,datas)
        
    def get_response(self,url,attr):
        response=requests.get(url)
        response.encoding='gb2312'#编码转换
        soup=BeautifulSoup(response.text,'lxml')
        table=soup.find_all('tbody')[1].tbody.tbody.table
        if attr:
            trs=table.find_all('tr',attrs={'class':attr})
        else:
            trs=table.find_all('tr')
        return trs
             
    def connect_mysql(self,sql,data):
        cursor = self.db.cursor()
        try:
            result=None
            if data:
                if isinstance(data[0],list):
                    cursor.executemany(sql,data)
                else:
                    cursor.execute(sql,data)
            else:
                cursor.execute(sql)
                result=cursor.fetchall()
        except Exception as e:
            print(e)
            self.db.rollback();
        finally:
            cursor.close()
            self.db.commit(); #提交操作
            return result

if __name__=='__main__':
    Administrative()

数据库脚本

DROP TABLE IF EXISTS `china`;
CREATE TABLE `china`  (
  `cid` int(255) NOT NULL AUTO_INCREMENT,
  `province_name` varchar(255),
  `city_code` varchar(255),
  `city_name` varchar(255),
  `county_code` varchar(255),
  `county_name` varchar(255),
  PRIMARY KEY (`cid`) USING BTREE
)

效果图

我的个人博客网站是：www.coderyyn.cn
上面会不定期分享有关爬虫、算法、环境搭建以及有趣的帖子
欢迎大家一起交流学习

转载请注明