importrequestsimportthreadpoolimporttimeimportos,sysimportrefrom lxml importetreefrom lxml.html importtostringclassScrapDemo():
next_page_url="" #下一页的URL
page_num=1 #当前页
detail_url_list=0 #详情页面URL地址list
deepth=0 #设置抓取的深度
headers ={"user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/68.0.3440.84 Safari/537.36"}
fileNum=0def __init__(self,url):
self.scrapyIndex(url)def threadIndex(self,urllist): #开启线程池
if len(urllist) ==0:print("请输入需要爬取的地址")returnFalse
ScrapDemo.detail_url_list=len(urllist)
pool=threadpool.ThreadPool(len(urllist))
requests=threadpool.makeRequests(self.detailScray,urllist)for req inrequests:
pool.putRequest(req)
time.sleep(0.5)
pool.wait()def detailScray(self,url): #获取html结构
if not url == "":
url='http://xiaohua.zol.com.cn/{}'.format(url)
res=requests.get(url,headers=ScrapDemo.headers)
html=res.text#element=etree.HTML(html)
#divEle=element.xpath("//div[@class='article-text']")[0] # Element div
self.downloadText(html)def downloadText(self,ele): #抓取数据并存为txt文件
clist = re.findall('
|)+','',clist[index])
content="".join(clist)#print(content)
basedir=os.path.dirname(__file__)
filePath=os.path.join(basedir)
filename="xiaohua{0}-{1}.txt".format(ScrapDemo.deepth,str(ScrapDemo.fileNum))
file=os.path.join(filePath,'file_txt',filename)try:
f=open(file,"w")
f.write(content)if ScrapDemo.fileNum == (ScrapDemo.detail_url_list - 1):print(ScrapDemo.next_page_url)print(ScrapDemo.deepth)if not ScrapDemo.next_page_url == "":
self.scrapyIndex(ScrapDemo.next_page_url)exceptException as e:print("Error:%s" %str(e))
ScrapDemo.fileNum=ScrapDemo.fileNum+1
print(ScrapDemo.fileNum)defscrapyIndex(self,url):if not url == "":
ScrapDemo.fileNum=0
ScrapDemo.deepth=ScrapDemo.deepth+1
print("开启第{0}页抓取".format(ScrapDemo.page_num))
res=requests.get(url,headers=ScrapDemo.headers)
html=res.text
element=etree.HTML(html)
a_urllist=element.xpath("//a[@class='all-read']/@href") #当前页所有查看全文
next_page=element.xpath("//a[@class='page-next']/@href") #获取下一页的url
ScrapDemo.next_page_url='http://xiaohua.zol.com.cn/{}'.format(next_page[0])if not len(next_page) == 0 and ScrapDemo.next_page_url !=url:
ScrapDemo.page_num=ScrapDemo.page_num+1self.threadIndex(a_urllist[:])else:print('下载完成，当前页数为{}页'.format(ScrapDemo.page_num))
sys.exit()
