?? 思路：先組裝 需要訪問的url 鏈接，然后用asyncio協程批量去aiohttp請求，把返回的response數據 用BeautifulSoup處理得到我們想要的結果，然后把數據插入mongo數據庫。

import asyncio import time import aiohttp import async_timeout from bs4 import BeautifulSoup import pymongomyclient = pymongo.MongoClient("mongodb://localhost:27017/") mydb = myclient["python"] mycol = mydb["movie"]''''異步并發獲取url數據，爬蟲某網'''temp_data = [] linklist = [] link_texts = [] link_nums = []msg = "https://www.xxx.com/mdb/film/list/year-1908/o0d0p{}.html" headers = {'User-Agent': 'Mozilla/5.0 (Windows; U; Windows NT 6.1; en-US; rv:1.9.1.6) Gecko/20091201 Firefox/3.5.6' }urls = [msg.format(i) for i in range(1, 7)] print(urls) ##打印url 數組 data = bytearray()async def fetch(session, url):with async_timeout.timeout(10):async with session.get(url) as response:html = await response.text(encoding=None, errors='ignore')return response.status,htmlasync def main(url):async with aiohttp.ClientSession() as session:status,html = await fetch(session, url)if status == 200:return htmlelse:return ''if __name__ == '__main__':start = time.time()loop = asyncio.get_event_loop()tasks = [main(url) for url in urls]# 返回一個列表,內容為各個tasks的返回值status_list = loop.run_until_complete(asyncio.gather(*tasks))print(len([status_list]))for html in status_list:soup = BeautifulSoup(html)soup = soup.find('ul', attrs={'class': 'inqList'})for x in soup.find_all('li'):aTag = x.find('a')divTag = x.find('div')link = aTag.get('href')divaTag = divTag.find('a')divbTag = divTag.find('b')link_text = divaTag.stringif link_text:link_texts.append(link_text)if link:linklist.append(link)if divbTag:link_num = divbTag.stringelse:link_num = 0link_nums.append(link_num)mydict = {"name": link_text, "socre": link_num, "url": "https://www.1905.com"+link}inser = mycol.insert_one(mydict) #插入數據print(link_texts)print(linklist)print(link_nums)print(len(link_texts))print(len(linklist))print(len(link_nums))end = time.time()print("cost time:", end - start)

讀取MongoDb里面我們插入的數據

???????class MongoDb:def __init__(self):myclient = pymongo.MongoClient("mongodb://localhost:27017/")mydb = myclient["python"]self.mycol = mydb["movie"]mdb = MongoDb() for x in mdb.mycol.find({},{ "_id": 0, "name": 1, "socre": 1,"url":1}).sort("socre",-1):print(x)

總結

以上是生活随笔為你收集整理的Python异步高并发批量读取URL链接的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。