-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathxueqiu.py
119 lines (102 loc) · 7.93 KB
/
xueqiu.py
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
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
"""
统计雪球大V元卫南收到的打赏金额
元卫南的原创专栏地址：https://xueqiu.com/2227798650/column
元卫南的原创专栏分页列表数据第一页的API：https://xueqiu.com/statuses/original/timeline.json?user_id=2227798650&page=1
元卫南的原创专栏某一篇文章的打赏数据的API：https://xueqiu.com/statuses/reward/list_by_user.json?status_id=118077741&page=1&size=14
列表的每一项有一个超链接，通过这个超链接可以组装这一项对应的详情的打赏API
https://xueqiu.com/statuses/original/timeline.json?user_id=2227798650&page=1
拿到 id 替换到下面的status_id=值
https://xueqiu.com/statuses/reward/list_by_user.json?status_id=183208733&page=1&size=20
"""
import json
import requests
class xueqiu:
def __init__(self):
self.domain = 'https://xueqiu.com' # 雪球的域名
self.page_list_api = 'https://xueqiu.com/statuses/original/timeline.json?user_id={user_id}&page={page_num}' # 雪球某个人的帖子分页数据API
self.reward_api = 'https://xueqiu.com/statuses/reward/list_by_user.json?status_id={status_id}&page=1&size=20' # 某个帖子的打赏数据API
self.user_id = '6784593966' # 元卫南的用户ID 2227798650 盛京剑客id 6784593966
self.user = '元卫南'
self.headers = {
# "User-Agent": "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/78.0.3904.108 Safari/537.36",
# "Cookie": "aliyungf_tc=AQAAADriOUCilQoAxZ5btPQfYv7152ox; acw_tc=2760824915856669537353368e2ea5d4c1b87e45dadece330ae07e755b96f1; xq_a_token=2ee68b782d6ac072e2a24d81406dd950aacaebe3; xqat=2ee68b782d6ac072e2a24d81406dd950aacaebe3; xq_r_token=f9a2c4e43ce1340d624c8b28e3634941c48f1052; xq_id_token=eyJ0eXAiOiJKV1QiLCJhbGciOiJSUzI1NiJ9.eyJ1aWQiOi0xLCJpc3MiOiJ1YyIsImV4cCI6MTU4NzUyMjY2MSwiY3RtIjoxNTg1NjY2OTA4NDgwLCJjaWQiOiJkOWQwbjRBWnVwIn0.YCQ_yUlzhRvTiUgz1BWWDFrsmlxSgsbaaKs0cxsdxnOaMhIjF0qUX-5WNeqfRXe15I5cPHiFf-5AzeRZgjy0_bSId2-jycpDWuSIseOY07nHM306A8Y1vSJJx4Q9gFnWx4ETpbdu1VXyMYKpwVIKfmSb5sbGZYyHDJPQQuNTfIAtPBiIeHWPDRB-wtf0qa5FNSMK3LKHRZooXjUgh-IAFtQihUIr9D81tligmjNYREntMY1gLg5Kq6GjgivfF9CFc11sJ11fZxnSw9e8J_Lmx8XXxhwHv-j4-ANUSIuglM4cT6yCsWa3pGAVMN18r2cV72JNkk343I05DevQkbX8_A; u=481585666954081; Hm_lvt_1db88642e346389874251b5a1eded6e3=1585666971; device_id=24700f9f1986800ab4fcc880530dd0ed; Hm_lpvt_1db88642e346389874251b5a1eded6e3=1585667033"
'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/63.0.3239.132 Safari/537.36'
# 'user-agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/74.0.3729.169 Safari/537.36',
# 'Cookie': 'Hm_lvt_1db88642e346389874251b5a1eded6e3=1625212833; device_id=9d0e433c475175c6fdf06e3dd6a66304; xq_is_login=1; u=1714339330; is_overseas=0; Hm_lpvt_1db88642e346389874251b5a1eded6e3=1625212962'
} # 构造请求头，主要是user-agent、Cookie
#雪球更新新的反爬机制
headers = {
"User-Agent": "Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/63.0.3239.132 Safari/537.36"}
session = requests.Session()
session.get("https://xueqiu.com/", headers=self.headers)
aaa =session.get(self.page_list_api.format(user_id=self.user_id, page_num=1),headers=self.headers)
first_page_response = session.get(self.page_list_api.format(user_id=self.user_id, page_num=1),
headers=self.headers)
first_json_data = json.loads(first_page_response.text)
print("-------测试-------")
print(first_json_data)
print("-------分割线---------")
#打印请求头
'''self.headers = {
'user-agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10.14; rv:63.0) Gecko/20100101 Firefox/63.0',
'Cookie': '_ga=GA1.2.622531642.1537177620; device_id=15e29e08eb8eabfad484e4f725fba482; s=eq13zbsfyd; '
'bid=193a704f707fd9e5d38e9258755772d3_jn00hppu; aliyungf_tc=AQAAANX82DG0hQMAet/nc6o08xOdn7Z6; '
'_gid=GA1.2.1434884156.1544420139; snbim_minify=true; xq_a_token=6125633fe86dec75d9edcd37ac089d8aed148b9e; '
'xq_a_token.sig=CKaeIxP0OqcHQf2b4XOfUg-gXv0; xq_r_token=335505f8d6608a9d9fa932c981d547ad9336e2b5; '
'xq_r_token.sig=i9gZwKtoEEpsL9Ck0G7yUGU42LY; u=621544438231589; '
'Hm_lvt_1db88642e346389874251b5a1eded6e3=1544161803,1544420139,1544438050,1544451680; '
'__utma=1.622531642.1537177620.1544082461.1544451680.61; __utmc=1; '
'__utmz=1.1544451680.61.2.utmcsr=baidu|utmccn=(organic)|utmcmd=organic; '
'__utmb=1.1.10.1544451680; Hm_lpvt_1db88642e346389874251b5a1eded6e3=1544452116',
} # 构造请求头，主要是user-agent、Cookie'''
self.sum_after_deduct_fee = 0 # 雪球扣除1%的服务费后元卫南拿到的打赏总额
self.sum_from_other_person = 0 # 所有人给元卫南打赏了多少钱，即在元卫南拿到的钱的基础上加上1%的服务费
def crawl(self):
"""
主要的爬取逻辑
:return: 收到的打赏总额sum_after_deduct_fee，球友打赏的总额sum_from_other_person，
两者相差1%的服务费，记得总额都要除以100，因为雪球金额的表示法是乘以100的，比如98.12雪球表示成了9812
"""
#认证
session1 = requests.Session()
session1.get("https://xueqiu.com/", headers=self.headers)
first_page_response = session1.get(self.page_list_api.format(user_id=self.user_id, page_num=1),
headers=self.headers) # 先请求第一页的数据，获取总共有多少页等相关信息
first_page_json_data = json.loads(first_page_response.text) # 解析第一页的数据
max_page = first_page_json_data['maxPage'] # 原创文章最多有几个分页列表 maxPage 报错 等待 写死
#max_page = 102
total_reward = self.sum_reward_in_page(first_page_json_data) # 第一页的打赏总额
print(total_reward)
for page_num in range(2, max_page + 1):
response = session1.get(self.page_list_api.format(user_id=self.user_id, page_num=page_num),
headers=self.headers) # 分页请求
json_data = json.loads(response.text) # 解析数据
total_reward += self.sum_reward_in_page(json_data)
return {'sum_after_deduct_fee': total_reward / 100, 'sum_from_other_person': total_reward / 0.99 / 100}
# 统计打赏
def sum_reward_in_page(self, json_data):
result = 0
# print('1')
#如果 json数据不为空 且 字段中包含 list 同时list的值>0
'''
#调试
if json_data is not None:
print('json_data is not None')
print(json_data) # 打印出错 {'error_description': '遇到错误，请刷新页面或者重新登录帐号后再试', 'error_uri': '/statuses/original/timeline.json', 'error_data': None, 'error_code': '400016'}
if 'list' in json_data:
print('listin json_data')
if 'items' in json_data:
print('items in json_data')'''
print(json_data)
#获取session 认证
session1 = requests.Session()
session1.get("https://xueqiu.com/", headers=self.headers)
if json_data is not None and 'list' in json_data and len(json_data['list']) > 0:
for row in json_data['list']:
reward_response = session1.get(self.reward_api.format(status_id=row['id']),headers=self.headers) # 获取打赏数据
reward_data = json.loads(reward_response.text) # 解析打赏数据
result += int(reward_data['reward_amount']) # 累加打赏的钱 reward_amount
return result
if __name__ == '__main__':
obj = xueqiu()
print(obj.crawl())