先上代碼
# -*- coding:utf-8 -*-
import requests
from lxml import etree
import csv
import sys
reload(sys)
sys.setdefaultencoding('utf-8')
start_url = "http://guba.eastmoney.com/list,meigu_1.html"
headers = {
"User-Agent": "Mozilla / 5.0(Windows NT 6.1;Win64;x64)"
"AppleWebKit / 537.36(KHTML, likeGecko)"
"Chrome / 58.0.3029.110"
"Safari / 537.36"
}
# def get_total_page(start_url):
# html = requests.get(url=start_url, headers=headers).content
# selector = etree.HTML(html)
# sum_page = selector.xpath("http://span[@class='sumpage']/text()")
# return sum_page
def parse_title():
# sum_page = get_total_page(start_url)
rows = []
for num in range(1, 23):
url = "http://guba.eastmoney.com/list,meigu_" + str(num) + ".html"
html = requests.get(url=url, headers=headers).content
selector = etree.HTML(html)
items = selector.xpath("http://div[@id='articlelistnew']/div[position()>1 and position()<last()]")
for item in items:
title = item.xpath("span[@class='l3']/a/text()")[0].decode(encoding='utf-8')
author_temp = item.xpath("span[@class='l4']/a/text()") if item.xpath("span[@class='l4']/a/text()") else [
u'匿名網(wǎng)友']
author = author_temp[0].decode(encoding='utf-8')
read = item.xpath("span[@class='l1']/text()")[0]
comment_num = item.xpath("span[@class='l2']/text()")[0]
post_time = item.xpath("span[@class='l6']/text()")[0]
last_update = item.xpath("span[@class='l5']/text()")[0]
link = item.xpath("span[@class='l3']/a/@href")
complete_link = 'http://guba.eastmoney.com' + link[0] if str(link[0]).startswith('/') else 'http://guba.eastmoney.com/' + link[0]
rows.append(
{'title': title, 'author': author, 'read': read, 'comment_num': comment_num, 'post_time': post_time,
'last_update': last_update, 'link': link, 'complete_link': complete_link})
return rows
def parse_content_comment():
links = []
temp = parse_title()
for item in temp:
links.append(item['link'][0])
rows = []
for link in links[0:8]:
url = "http://guba.eastmoney.com/" + link
html = requests.get(url=url, headers=headers).text.decode(encoding='utf-8')
selector = etree.HTML(html)
lines = {}
content = ''
contents = selector.xpath("http://div[@class='stockcodec']/div[@id='zw_body']/p/text()") if selector.xpath("http://div[@class='stockcodec']/div[@id='zw_body']/p/text()") else [u'none']
for item in contents:
content += item
lines['content'] = content
comments = selector.xpath("http://div[@id='zwlist']")
for item in comments:
if item.xpath("div[@class='zwli clearfix']"):
name = ''
names = item.xpath("div/div/div/div[@class='zwlianame']/span/a/text()")
for na in names:
name += na
comment = ''
comments = item.xpath("div/div/div/div[@class='zwlitext stockcodec']/text()")
for co in comments:
comment += co.strip()
time = ''
times = item.xpath("div/div/div/div[@class='zwlitime']/text()")
for ti in times:
time += ti
lines['name'] = name
lines['comment'] = comment
lines['time'] = time
else:
lines['name'] = 'none'
lines['comment'] = 'none'
lines['time'] = 'none'
rows.append(lines)
for link in links[8:]:
url = "http://guba.eastmoney.com" + link
html = requests.get(url=url, headers=headers).text
selector = etree.HTML(html)
lines = {}
content = ''
contents = selector.xpath("http://div[@class='stockcodec']/text()") if selector.xpath("http://div[@class='stockcodec']/text()") else [u'none']
for co in contents:
content += co.strip()
lines['content'] = content
comments = selector.xpath("http://div[@id='zwlist']")
for item in comments:
if item.xpath("div[@class='zwli clearfix']"):
name = ''
names = item.xpath("div/div/div/div[@class='zwlianame']/span/a/text()")
for na in names:
name += na
comment = ''
comments = item.xpath("div/div/div/div[@class='zwlitext stockcodec']/text()")
for co in comments:
comment += co
time = ''
times = item.xpath("div/div/div/div[@class='zwlitime']/text()")
for ti in times:
time += ti
lines['name'] = name
lines['comment'] = comment
lines['time'] = time
else:
lines['name'] = 'none'
lines['comment'] = 'none'
lines['time'] = 'none'
rows.append(lines)
return rows
if __name__ == "__main__":
headlines1 = ['title', 'author', 'read', 'comment_num', 'post_time', 'last_update', 'link', 'complete_link']
headlines2 = ['content', 'name', 'comment', 'time']
# get_total_page(start_url)
rows1 = parse_title()
rows2 = parse_content_comment()
with open('eastmoney1.csv', 'wb') as f:
f_csv = csv.DictWriter(f, headlines1)
f_csv.writeheader()
f_csv.writerows(rows1)
with open('eastmoney2.csv', 'wb') as f:
f_csv = csv.DictWriter(f, headlines2)
f_csv.writeheader()
f_csv.writerows(rows2)
結(jié)果
之前不知道為何會(huì)亂碼，這個(gè)星期這個(gè)作業(yè)就一直在我心里糾纏著我，今天冷靜的分析了一下原因储耐，終于發(fā)現(xiàn)了問(wèn)題钝荡，別提有多開(kāi)心了街立。
問(wèn)題就出在這里
html = requests.get(url=url, headers=headers).text
html = requests.get(url=url, headers=headers).content
看源碼
@property
def text(self):
"""Content of the response, in unicode.
If Response.encoding is None, encoding will be guessed using
``chardet``.
The encoding of the response content is determined based solely on HTTP
headers, following RFC 2616 to the letter. If you can take advantage of
non-HTTP knowledge to make a better guess at the encoding, you should
set ``r.encoding`` appropriately before accessing this property.
"""
#content的完整代碼就不貼了。
@property
def content(self):
"""Content of the response, in bytes."""
.text返回的是Unicode型的數(shù)據(jù)埠通。
.content返回的是bytes型也就是二進(jìn)制的數(shù)據(jù)
之前一直用.content來(lái)解析所以一直出錯(cuò)赎离。
心頭只恨總算除掉了！又漲經(jīng)驗(yàn)了端辱！
