思路：使用Python爬蟲對騰訊疫情網站世界疫情數據進行爬取，封裝成一個函數返回一個

字典數據格式的對象，寫另一個方法調用該函數接收返回值，和數據庫取得連接后把

數據存儲到mysql數據庫。

CREATE TABLE world( id INT(11) NOT NULL AUTO_INCREMENT, dt DATETIME NOT NULL COMMENT ’日期’, c_name VARCHAR(35) DEFAULT NULL COMMENT ’國家’, continent VARCHAR(35) DEFAULT NULL COMMENT ’所屬大洲’, nowConfirm INT(11) DEFAULT NULL COMMENT ’累計確診’, confirm INT(11) DEFAULT NULL COMMENT ’當日現存確診’, confirmAdd INT(11) DEFAULT NULL COMMENT ’當日新增確診’, suspect INT(11) DEFAULT NULL COMMENT ’剩余疑似’, heal INT(11) DEFAULT NULL COMMENT ’累計治愈’, dead INT(11) DEFAULT NULL COMMENT ’累計死亡’, confirmAddCut INT(11) DEFAULT NULL COMMENT ’confirmAddCut’, confirmCompare INT(11) DEFAULT NULL COMMENT ’confirmCompare’, nowConfirmCompare INT(11) DEFAULT NULL COMMENT ’nowConfirmCompare’, healCompare INT(11) DEFAULT NULL COMMENT ’healCompare’, deadCompare INT(11) DEFAULT NULL COMMENT ’deadCompare’, PRIMARY KEY(id))ENGINE=INNODB DEFAULT CHARSET=utf8mb4;

注意建立的表，數據的名字，數據的長度，數據的類型，主鍵的定義一定要小心仔細。

這里博主出現了幾個小錯誤：

①數據表的主鍵不可以設置為日期，因為在之后爬取數據之后可以看到，網站給的數據是同一天的，

因為主鍵不可以有重復，所以相同的日期是不可以作為主鍵定義的。

②設置int類型的id作為數據表的主鍵，那么存在一個問題，在往表里插入數據的時候，id位置的數據值需要考慮，

這個方法可以解決：可以在傳值的時候把id的值設定為 0，前提是id是自增的，

這樣數據庫是可以自己處理id的，依然是從0開始自增，這樣避免了不給id傳值導致Null的異常。

③博主使用的mysql可視化工具默認在一個頁面顯示30條記錄，在右上角可以改變顯示的記錄數，因為本次插入的

是185條數據，所以在插入完之后如果發現數據不對，可以看看可視化工具是不是有什么設置導致的。

'''獲取全球疫情數據'''def get_world_data(): url=’https://api.inews.qq.com/newsqa/v1/automation/foreign/country/ranklist’ headers={’user-agent’: ’WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/86.0.4240.198 Safari/537.36’} # 創建會話對象 # session = requests.session() # 請求接口 # result = session.get(’https://api.inews.qq.com/newsqa/v1/automation/foreign/country/ranklist’) # 打印結果 # print(result.text) res = requests.get(url, headers=headers) # print(res.text) response_data_0 = json.loads(res.text.replace(’jQuery34102848205531413024_1584924641755(’, ’’)[:-1]) #轉化json對象 # print(response_data_0.keys()) # print(response_data_0) response_data_1=response_data_0[’data’] # print(response_data_1) # print(response_data_1[0].keys()) # data = jsonpath.jsonpath(resJson_1, ’$.data.*’) # print(resJson_1.keys()) # for d in data: # res = ’日期:’ + d[’date’] + ’--’ + d[’continent’] + ’--’ + d[’name’] + ’--’ + ’新增確診:’ + str( # d[’confirmAdd’]) + ’累計確診:’ + str(d[’confirm’]) + ’治愈:’ + str(d[’heal’]) + ’死亡:’ + str(d[’dead’]) # file = r’C:/Users/Administrator/Desktop/world_data.txt’ # with open(file, ’w+’, encoding=’utf-8’) as f: # f.write(res + ’n’) # 加n換行顯示 # f.close() world={} for i in response_data_1: temp=i[’y’]+’.’+i[’date’] tup = time.strptime(temp, ’%Y.%m.%d’) dt = time.strftime(’%Y-%m-%d’, tup) # 改變時間格式，插入數據庫 日期 # print(ds) c_name=i[’name’] #國家 continent=i[’continent’] #所屬大洲 nowConfirm=i[’nowConfirm’] #現有確診 confirm=i[’confirm’] #累計確診 confirmAdd=i[’confirmAdd’] #新增確診 suspect=i[’suspect’] #現有疑似 heal=i[’heal’] #累計治愈 dead=i[’dead’] #累計死亡 confirmAddCut=i[’confirmAddCut’] confirmCompare=i[’confirmCompare’] nowConfirmCompare=i[’nowConfirmCompare’] healCompare=i[’healCompare’] deadCompare=i[’deadCompare’] world[c_name] = {’dt’:dt , ’continent’: continent, ’nowConfirm’: nowConfirm, ’confirm’: confirm, ’confirmAdd’: confirmAdd, ’suspect’: suspect, ’heal’: heal, ’dead’: dead, ’confirmAddCut’: confirmAddCut, ’confirmCompare’: confirmCompare, ’nowConfirmCompare’: nowConfirmCompare, ’healCompare’: healCompare, ’deadCompare’: deadCompare, } return world三、插入數據庫

def insert_world(): ''' 更新 world 表 :return: ''' cursor = None conn = None try: dic = get_world_data() print(dic) conn, cursor = get_conn() sql = 'insert into world values(%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)' sql_query = ’select %s=(select dt from world order by id desc limit 1)’ #對比當前最大時間戳 cursor.execute(sql_query,dic[’美國’][’dt’]) if not cursor.fetchone()[0]: print(f'{time.asctime()}開始插入世界數據') for k, v in dic.items(): # item 格式 {’2021-01-13’: {’confirm’: 41, ’suspect’: 0, ’heal’: 0, ’dead’: 1} cursor.execute(sql, [0,v.get(’dt’), k, v.get('continent'), v.get('nowConfirm'), v.get('confirm'), v.get('confirmAdd'),v.get('suspect'),v.get('heal'), v.get('dead') , v.get('confirmAddCut'), v.get('confirmCompare'), v.get('nowConfirmCompare'), v.get('healCompare'), v.get('deadCompare')]) conn.commit() # 提交事務 print(f'{time.asctime()}插入世界數據完畢') else: print(f'{time.asctime()}世界數據已是最新數據！') except: traceback.print_exc() finally: close_conn(conn, cursor)

總結一下在完成這兩個方法的過程中遇到的問題，首先是最基礎的問題，數據的類型和格式的轉換，這里主要是指json字符串和

Python里對應的數據對象（list和字典）。

（1）一般來講對我們而言，需要抓取的是某個網站或者某個應用的內容，提取有用的價值。內容一般分為三部分，

結構化的數據、半結構化的數據和非機構化數據。

1.結構化數據： 可以用統一的結構加以表示的數據。可以使用關系型數據庫表示和存儲，表現為二維形式的數據，一般特點是：數據以行為單位，

一行數據表示一個實體的信息，每一行的數據的屬性是相同的。2.半結構化數據： 結構化數據的一種形式，并不符合關系型數據庫或其他數據表的形式關聯起來的數據模型結構，但包含相關標記，

用來分隔語義元素以及對記錄和字段進行分層。因此他也被成為自描述的結構。常見的半結構數據有：html，xml和json等、

實際上是以樹或者圖的結構來存儲的。 對于半結構化數據，節點中屬性的順序是不重要的，不同的半結構化數據的屬性的個數是不一樣的。這樣的數據格式，

可以自由的表達很多有用的信息，

包含自描述信息。所以半結構化數據的擴展性很好，特別適合于在互聯網中大規模傳播。3.非結構化數據

就是沒有固定的結構。各種文檔，圖片，視頻或者音頻都屬于非結構化數據。對于這類數據，我們一般直接整體進行存儲，而且一般存儲為二進制形式。

原文鏈接：www.jb51.net/article/208448.htm

json（JavaScript Object Notation，JS對象標記）是一種輕量級的數據交換格式。

基于ECMAScript（w3c制定的JS規范）的一個子集，采用完全獨立于編程語言的文本格式來存儲和表示數據。

簡潔和清晰的層次結構使得JSON成為理想的數據交換語言。

特點：易于閱讀、易于機器生成、有效提升網絡速度。

JSON語法規則：

在JS語言中，一切都是對象。因此，任何支持的類型都可以通過json來表示。

例如字符串、數字，對象，數組。Js中對象和數組是比較特殊并且常用的兩種類型： 1、對象表示為鍵值對{name:’zhangsan’,age:’7’} 2、數據有逗號分隔[1,2,3,4,5] 3、花括號保存對象 4、方括號保存數組。js的對象就相當于python中的字典js的數組就相當于Python中的列表 因為json用來存儲js的對象或者數組，所以在Python中我們可以將json轉化為list或者dict。

解析json的包json： json.dumps(python的list或者dict)---->（返回值）---->json字符串。 json.loads(json字符串)------>（返回值）----->python的list或者dict.

json.dump(list/dict,fp)—>list，或者字典保存到json文件中。 json.load(fp)—>list/dict:從json文件中讀出json數據。

json鍵值對是用來保存js對象的一種方式，和js對象的寫法頁大同小異，比如：{“firstName”:“Json”,“Class”:“aid1111”}等價于下面這條js語句：{firstName:“Json”，Class：“aid1111”}。 很多人搞不清楚json和js對象的關系，甚至誰是誰都不清楚。其實可以這么理解：

【JSON是JS對象的字符串表達式，他使用文本形式表示一個JS對象的信息，本質是一個字符串。】如var obj = {a:“hello”,b:“World”}這是一個js對象。注意，鍵名也是可以用引號包裹的var json = ’ {“a”:“hello”,“b”:“World”}’這是一個json字符串，本質上是一個字符串。 JSON作為數據包格式傳輸的時候具有更高的效率，這是因為JSON不想xml那樣具有嚴格的閉合標簽，這就讓有效數據量與總數據包比大大提升，從而減少同等數據流量的情況下，網絡的傳輸的壓力大大減低。

之前寫過一篇關于爬取中國疫情數據的博客文章，那里爬取的每日疫情數據和全球爬取的疫情數據格式有一點點不同：

這是中國的疫情數據，注意箭頭指的地方，這里的data對應的key是字典

這是全球疫情，注意這里data對應的是list

數據的格式非常重要，因為在后續需要把網頁爬取的數據接受之后，還要把數據導入數據庫，所以中間數據的格式必須清楚，

比如list類型的可以通過下標去訪問，而字典只可以通過name來訪問，字典是不提供索引的，所以不可以通過下標訪問。還

有就是數據庫里的日期格式一定要注意轉換再插入。

（1）首先需要導入需要的包：

import requestsimport pymysqlimport timeimport jsonimport traceback

（2）通過request向被爬取網站的url發起一個請求（如果網站有反爬取手段，需要在請求里加上headers）獲取headers：

到指定網站，瀏覽器按F12，之后在網絡那一個選項里可以看到。

（3）獲取和解析數據

url=’https://api.inews.qq.com/newsqa/v1/automation/foreign/country/ranklist’ headers={’user-agent’: ’WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/86.0.4240.198 Safari/537.36’} res = requests.get(url, headers=headers) # print(res.text) response_data_0 = json.loads(res.text.replace(’jQuery34102848205531413024_1584924641755(’, ’’)[:-1]) #轉化json對象

這里進行了第一步解析，通過json.loads( ) 方法把從網頁獲取的json字符串數據轉化成Python對應的list或者字典。

如果第一步解析之后data對應的value不是list，那么可以進行第二次解析，本次操作中，世界疫情數據的data對

應的數據是一個list，所以也就不需要進行第二次轉化，可以直接通過list的下標去訪問。

數據轉化是必要的，在網絡中json字符串傳遞小巧安全速度快，但是我們讀取數據，如果直接對字符串進行操作

會非常不方便，所以我們需要解析json字符串，也就是通過json.loads(）方法把字符串轉化成Python對應的list或

者字典對象，這樣我們訪問操作這些數據會變得簡單。

以上就是Python爬蟲爬取全球疫情數據并存儲到mysql數據庫的步驟的詳細內容，更多關于python 爬取疫情數據存儲到mysql的資料請關注好吧啦網其它相關文章！