Python 爬虫 (四)

requests: 练手 雪qiu网

import requests
import json
import re
import pymysql
url = 'https://xueqiu.com/v4/statuses/public_timeline_by_category.json?since_id=-1&max_id=-1&count=10&category=-1'
headers = {
    'Cookie': 'aliyungf_tc=AQAAALoQF3p02gsAUhVFebQ3uBBNZn+H; xq_a_token=584d0cf8d5a5a9809761f2244d8d272bac729ed4; xq_a_token.sig=x0gT9jm6qnwd-ddLu66T3A8KiVA; xq_r_token=98f278457fc4e1e5eb0846e36a7296e642b8138a; xq_r_token.sig=2Uxv_DgYTcCjz7qx4j570JpNHIs; _ga=GA1.2.516718356.1534295265; _gid=GA1.2.1050085592.1534295265; u=301534295266356; device_id=f5c21e143ce8060c74a2de7cbcddf0b8; Hm_lvt_1db88642e346389874251b5a1eded6e3=1534295265,1534295722; Hm_lpvt_1db88642e346389874251b5a1eded6e3=1534295722',
    'User-Agent': 'Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/67.0.3396.99 Safari/537.36',
}
res = requests.get(url, headers=headers) #get请求,将url和头文件一并传入
response = res.content.decode('utf-8')  # content 和 request下的.read()作用是一样的
response = json.loads(response)#分析第一个页面 从第一个页面中提取下一个Ajax请求所需要的id
while True:
    if response['next_id'] != None:
        url = 'https://xueqiu.com/v4/statuses/public_timeline_by_category.json?since_id=-1&max_id={}&count=15&category=-1'
        fullurl = url.format(response['next_id']) #通过上面获取的id将需要浏览的下一个网页的url进行补全
        res = requests.get(fullurl, headers=headers)
        response = res.content.decode('utf-8')
        response = json.loads(response) #response是个字典
        # print(response)
        ans_text = response['list']
        # print(type(ans_text)) #list
        for i in ans_text:
            #i是字典
            rul  = re.compile(r'"topic_title":"(.*?)",') #通过正则将需要的数据提取出来
            rul2 = re.compile(r'"description":"(.*?)",')
            ans1 = rul.findall(i['data'])
            ans2 = rul2.findall(i['data'])
            print(ans1)  #type 为list
            print(ans2)
            print('-' * 50)
            
            #将数据存到数据库中
            connection = pymysql.connect(host='localhost',user='root',password='1234',db='xq')
        try:
            with connection.cursor() as cursor:
                # Create a new record
                sql = "INSERT INTO `xq_info` (`title`, `info`) VALUES (%s, %s)"
                cursor.execute(sql, (ans1[0],ans2[0]))
            connection.commit()
        finally:
            connection.close()
        print('&'*50)
    else:
        break