⑴ 基於python的scrapy爬蟲,關於增量爬取是怎麼處理的
一、增量爬取的思路:即保存上一次狀態,本次抓取時與上次比對,如果不在上次的狀態中,便視為增量,保存下來。對於scrapy來說,上一次的狀態是抓取的特徵數據和上次爬取的 request隊列(url列表),request隊列可以通過request隊列可以通過scrapy.core.scheler的pending_requests成員得到,在爬蟲啟動時導入上次爬取的特徵數據,並且用上次request隊列的數據作為start url進行爬取,不在上一次狀態中的數據便保存。
二、選用BloomFilter原因:對爬蟲爬取數據的保存有多種形式,可以是資料庫,可以是磁碟文件等,不管是資料庫,還是磁碟文件,進行掃描和存儲都有很大的時間和空間上的開銷,為了從時間和空間上提升性能,故選用BloomFilter作為上一次爬取數據的保存。保存的特徵數據可以是數據的某幾項,即監控這幾項數據,一旦這幾項數據有變化,便視為增量持久化下來,根據增量的規則可以對保存的狀態數據進行約束。比如:可以選網頁更新的時間,索引次數或是網頁的實際內容,cookie的更新等
⑵ python爬蟲可以做什麼
1、收集數據
Python爬蟲程序可用於收集數據,這是最直接和最常用的方法。由於爬蟲程序是一個程序,程序運行得非常快,不會因為重復的事情而感到疲倦,因此使用爬蟲程序獲取大量數據變得非常簡單、快速。
2、數據儲存
Python爬蟲可以將從各個網站收集的數據存入原始頁面資料庫。其中的頁面數據與用戶瀏覽器得到的HTML是完全一樣的。注意:搜索引擎蜘蛛在抓取頁面時,也做一定的重復內容檢測,一旦遇到訪問許可權很低的網站上有大量抄襲、採集或者復制的內容,很可能就不再爬行。
3、網頁預處理
Python爬蟲可以將爬蟲抓取回來的頁面,進行各種步驟的預處理。比如提取文字、中文分詞、消除噪音、索引處理、特殊文字處理等。
4、提供檢索服務、網站排名
Python爬蟲在對信息進行組織和處理之後,為用戶提供關鍵字檢索服務,將用戶檢索相關的信息展示給用戶。同時可以根據頁面的PageRank
值來進行網站排名,這樣Rank值高的網站在搜索結果中會排名較前,當然也可以直接使用Money購買搜索引擎網站排名。
5、科學研究
在線人類行為、在線社群演化、人類動力學研究、計量社會學、復雜網路、數據挖掘等領域的實證研究都需要大量數據,Python爬蟲是收集相關數據的利器。
⑶ Python爬蟲(七)數據處理方法之JSON
JSON 指的是 JavaScript 對象表示法(JavaScript Object Notation),是輕量級的文本數據交換格式,且具有自我描述性,更易理解。
JSON看起來像python類型(列表,字典)的字元串。
在之前的文章中,我們說到了怎麼用response的方法,獲取到網頁正確解碼後的字元串。如果還有不懂的,可以先閱讀 Python爬蟲(三)Requests庫 。接下來以有道翻譯為例子,說說怎麼通過網頁解碼後的字元串,提取到翻譯結果。
再結合上述有道翻譯的例子,得到字典類型的返回結果,並提取出來翻譯結果。
將上述例子的dict_json換成str字元串,再寫入文本中。
執行完上述的程序,會得到一個fanyi.txt的文件,其結果如下:{"type": "ZH_CN2EN", "errorCode": 0, "elapsedTime": 1, "translateResult": [[{"src": "\u4eba\u751f\u82e6\u77ed\uff0c\u6211\u7528python", "tgt": "Life is too short, I use python"}]]}。這樣子的一份文檔,中文部分顯示的是二進制,且格式非常不利於閱讀,這並不是我們想要的結果。好在json.mps()為我們提供的兩個方法,以幫助我們更好閱讀文檔。
1.ensure_ascii,能夠讓中文顯示成中文;
2.indent,能夠讓下一行在第一行的基礎上空格。
其用法如下:
⑷ python爬蟲數據怎麼排列好後存儲到本地excel
第一步:分析網站的請求過程
我們在查看拉勾網上的招聘信息的時候,搜索Python,或者是PHP等等的崗位信息,其實是向伺服器發出相應請求,由伺服器動態的響應請求,將我們所需要的內容通過瀏覽器解析,呈現在我們的面前。
可以看到我們發出的請求當中,FormData中的kd參數,就代表著向伺服器請求關鍵詞為Python的招聘信息。
分析比較復雜的頁面請求與響應信息,推薦使用Fiddler,對於分析網站來說絕對是一大殺器。不過比較簡單的響應請求用瀏覽器自帶的開發者工具就可以,比如像火狐的FireBug等等,只要輕輕一按F12,所有的請求的信息都會事無巨細的展現在你面前。
經由分析網站的請求與響應過程可知,拉勾網的招聘信息都是由XHR動態傳遞的。
我們發現,以POST方式發出的請求有兩個,分別是companyAjax.json和positionAjax.json,它們分別控制當前顯示的頁面和頁面中包含的招聘信息。
可以看到,我們所需要的信息包含在positionAjax.json的Content->result當中,其中還包含了一些其他參數信息,包括總頁面數(totalPageCount),總招聘登記數(totalCount)等相關信息。
第二步:發送請求,獲取頁面
知道我們所要抓取的信息在哪裡是最為首要的,知道信息位置之後,接下來我們就要考慮如何通過Python來模擬瀏覽器,獲取這些我們所需要的信息。
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
def read_page(url, page_num, keyword): # 模仿瀏覽器post需求信息,並讀取返回後的頁面信息
page_headers = {
'Host': 'www.lagou.com',
'User-Agent': 'Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) '
'Chrome/45.0.2454.85 Safari/537.36 115Browser/6.0.3',
'Connection': 'keep-alive'
}
if page_num == 1:
boo = 'true'
else:
boo = 'false'
page_data = parse.urlencode([ # 通過頁面分析,發現瀏覽器提交的FormData包括以下參數
('first', boo),
('pn', page_num),
('kd', keyword)
])
req = request.Request(url, headers=page_headers)
page = request.urlopen(req, data=page_data.encode('utf-8')).read()
page = page.decode('utf-8')
return page
其中比較關鍵的步驟在於如何仿照瀏覽器的Post方式,來包裝我們自己的請求。
request包含的參數包括所要抓取的網頁url,以及用於偽裝的headers。urlopen中的data參數包括FormData的三個參數(first、pn、kd)
包裝完畢之後,就可以像瀏覽器一樣訪問拉勾網,並獲得頁面數據了。
第三步:各取所需,獲取數據
獲得頁面信息之後,我們就可以開始爬蟲數據中最主要的步驟:抓取數據。
抓取數據的方式有很多,像正則表達式re,lxml的etree,json,以及bs4的BeautifulSoup都是python3抓取數據的適用方法。大家可以根據實際情況,使用其中一個,又或多個結合使用。
?
1
2
3
4
5
6
7
8
9
10
11
def read_tag(page, tag):
page_json = json.loads(page)
page_json = page_json['content']['result']
# 通過分析獲取的json信息可知,招聘信息包含在返回的result當中,其中包含了許多其他參數
page_result = [num for num in range(15)] # 構造一個容量為15的佔位list,用以構造接下來的二維數組
for i in range(15):
page_result[i] = [] # 構造二維數組
for page_tag in tag:
page_result[i].append(page_json[i].get(page_tag)) # 遍歷參數,將它們放置在同一個list當中
page_result[i][8] = ','.join(page_result[i][8])
return page_result # 返回當前頁的招聘信息
第四步:將所抓取的信息存儲到excel中
獲得原始數據之後,為了進一步的整理與分析,我們有結構有組織的將抓取到的數據存儲到excel中,方便進行數據的可視化處理。
這里我用了兩個不同的框架,分別是老牌的xlwt.Workbook、以及xlsxwriter。
?
1
2
3
4
5
6
7
8
9
10
11
12
def save_excel(fin_result, tag_name, file_name):
book = Workbook(encoding='utf-8')
tmp = book.add_sheet('sheet')
times = len(fin_result)+1
for i in range(times): # i代表的是行,i+1代表的是行首信息
if i == 0:
for tag_name_i in tag_name:
tmp.write(i, tag_name.index(tag_name_i), tag_name_i)
else:
for tag_list in range(len(tag_name)):
tmp.write(i, tag_list, str(fin_result[i-1][tag_list]))
book.save(r'C:\Users\Administrator\Desktop\%s.xls' % file_name)
首先是xlwt,不知道為什麼,xlwt存儲到100多條數據之後,會存儲不全,而且excel文件也會出現「部分內容有問題,需要進行修復」我檢查了很多次,一開始以為是數據抓取的不完全,導致的存儲問題。後來斷點檢查,發現數據是完整的。後來換了本地的數據進行處理,也沒有出現問題。我當時的心情是這樣的:
到現在我也沒弄明白,有知道的大神希望能告訴我ლ(╹ε╹ლ)
?
1
2
3
4
5
6
7
8
9
10
11
12
13
def save_excel(fin_result, tag_name, file_name): # 將抓取到的招聘信息存儲到excel當中
book = xlsxwriter.Workbook(r'C:\Users\Administrator\Desktop\%s.xls' % file_name) # 默認存儲在桌面上
tmp = book.add_worksheet()
row_num = len(fin_result)
for i in range(1, row_num):
if i == 1:
tag_pos = 'A%s' % i
tmp.write_row(tag_pos, tag_name)
else:
con_pos = 'A%s' % i
content = fin_result[i-1] # -1是因為被表格的表頭所佔
tmp.write_row(con_pos, content)
book.close()
這是使用xlsxwriter存儲的數據,沒有問題,可以正常使用。
到從為止,一個抓取拉勾網招聘信息的小爬蟲就誕生了。
附上源碼
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
#! -*-coding:utf-8 -*-
from urllib import request, parse
from bs4 import BeautifulSoup as BS
import json
import datetime
import xlsxwriter
starttime = datetime.datetime.now()
url = r'http://www.lagou.com/jobs/positionAjax.json?city=%E5%8C%97%E4%BA%AC'
# 拉鉤網的招聘信息都是動態獲取的,所以需要通過post來遞交json信息,默認城市為北京
tag = ['companyName', 'companyShortName', 'positionName', 'ecation', 'salary', 'financeStage', 'companySize',
'instryField', 'companyLabelList'] # 這是需要抓取的標簽信息,包括公司名稱,學歷要求,薪資等等
tag_name = ['公司名稱', '公司簡稱', '職位名稱', '所需學歷', '工資', '公司資質', '公司規模', '所屬類別', '公司介紹']
def read_page(url, page_num, keyword): # 模仿瀏覽器post需求信息,並讀取返回後的頁面信息
page_headers = {
'Host': 'www.lagou.com',
'User-Agent': 'Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) '
'Chrome/45.0.2454.85 Safari/537.36 115Browser/6.0.3',
'Connection': 'keep-alive'
}
if page_num == 1:
boo = 'true'
else:
boo = 'false'
page_data = parse.urlencode([ # 通過頁面分析,發現瀏覽器提交的FormData包括以下參數
('first', boo),
('pn', page_num),
('kd', keyword)
])
req = request.Request(url, headers=page_headers)
page = request.urlopen(req, data=page_data.encode('utf-8')).read()
page = page.decode('utf-8')
return page
def read_tag(page, tag):
page_json = json.loads(page)
page_json = page_json['content']['result'] # 通過分析獲取的json信息可知,招聘信息包含在返回的result當中,其中包含了許多其他參數
page_result = [num for num in range(15)] # 構造一個容量為15的list佔位,用以構造接下來的二維數組
for i in range(15):
page_result[i] = [] # 構造二維數組
for page_tag in tag:
page_result[i].append(page_json[i].get(page_tag)) # 遍歷參數,將它們放置在同一個list當中
page_result[i][8] = ','.join(page_result[i][8])
return page_result # 返回當前頁的招聘信息
def read_max_page(page): # 獲取當前招聘關鍵詞的最大頁數,大於30的將會被覆蓋,所以最多隻能抓取30頁的招聘信息
page_json = json.loads(page)
max_page_num = page_json['content']['totalPageCount']
if max_page_num > 30:
max_page_num = 30
return max_page_num
def save_excel(fin_result, tag_name, file_name): # 將抓取到的招聘信息存儲到excel當中
book = xlsxwriter.Workbook(r'C:\Users\Administrator\Desktop\%s.xls' % file_name) # 默認存儲在桌面上
tmp = book.add_worksheet()
row_num = len(fin_result)
for i in range(1, row_num):
if i == 1:
tag_pos = 'A%s' % i
tmp.write_row(tag_pos, tag_name)
else:
con_pos = 'A%s' % i
content = fin_result[i-1] # -1是因為被表格的表頭所佔
tmp.write_row(con_pos, content)
book.close()
if __name__ == '__main__':
print('**********************************即將進行抓取**********************************')
keyword = input('請輸入您要搜索的語言類型:')
fin_result = [] # 將每頁的招聘信息匯總成一個最終的招聘信息
max_page_num = read_max_page(read_page(url, 1, keyword))
for page_num in range(1, max_page_num):
print('******************************正在下載第%s頁內容*********************************' % page_num)
page = read_page(url, page_num, keyword)
page_result = read_tag(page, tag)
fin_result.extend(page_result)
file_name = input('抓取完成,輸入文件名保存:')
save_excel(fin_result, tag_name, file_name)
endtime = datetime.datetime.now()
time = (endtime - starttime).seconds
print('總共用時:%s s' % time)
⑸ Python爬蟲數據處理
把car_list函數里的for循環去掉, 然後直接return list_text即可。 只有「第一個字」就是因為這個for循環。這個list_text就已經是汽車名稱的列表了, 如果再遍歷這個列表的話,每個item就是字元串類型的單個汽車名稱,所以你的item[0]就只能是第一個字了唄~