python实现 获取b站主播直播间 粉丝牌信息

三下五除二

前言

用于实现通过牌子逆向查主播信息这个功能。
插件基于Nonebot2开发，链接：https://github.com/Ikaros-521/nonebot_plugin_searchBiliInfo
工程下载

github：https://github.com/Ikaros-521/get_bili_medal_list
gitee：https://gitee.com/ikaros-521/get_bili_medal_list
目录结构

data.py数据源自vtbs.moe
1.py用于获取数据
2.py用于中断时候的下标检索
data_medal.py用于存储用户结果数据
API

https://api.live.bilibili.com/xlive/web-room/v1/index/getInfoByUser?from=0&not_mock_enter_effect=1&room_id= 传入主播的房间号，解析json["data"]["medal"]["up_medal"]["medal_name"]，即可。
使用

安装相应的第三方库（aiohttp）后，python 1.py 即可。
核心源码

1.py

1. import json
2. import asyncio
3. import aiohttp
4. import time
5. from itertools import islice
7. # data.py存储着从vtbs.moe获取的主播数据
8. from data import DATA
9. # data_medal.py用于存储获取的主播牌子信息
10. from data_medal import DATA_MEDAL
12. # 用于存储牌子数据
13. data_medal_json = DATA_MEDAL
14. # 请求头
15. header1 = {
16.     'content-type': 'text/plain; charset=utf-8',
17.     # 下方填入你的cookie喵
18.     'cookie': "",
19.     'user-agent': 'Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/94.0.4606.71 Safari/537.36 Core/1.94.186.400 QQBrowser/11.3.5195.400'
20. }
21. # 计数用
22. num = 0
24. # 获取主播牌子信息 传入主播房间号
25. async def get_medal(roomid):
26.     global header1
28.     API_URL = 'https://api.live.bilibili.com/xlive/web-room/v1/index/getInfoByUser?from=0&not_mock_enter_effect=1&room_id=' + str(roomid)
29.     async with aiohttp.ClientSession(headers=header1) as session:
30.         try:
31.             async with session.get(url=API_URL, headers=header1) as response:
32.                 if response.status != 200:
33.                     response.raise_for_status()
34.                 ret = await response.json()
35.         except aiohttp.ClientError as e:
36.             print(e)
37.             # 睡眠个3s
38.             await asyncio.sleep(3)
39.             # 重试一次
40.             async with session.get(url=API_URL, headers=header1) as response:
41.                 if response.status != 200:
42.                     response.raise_for_status()
43.                 ret = await response.json()
44.             
45.     return ret
48. async def main():
49.     global data_medal_json, num
51.     # print(type(DATA))
53.     # 遍历本地vtb数据 第二个参数的起始值，跳过前n个数据(这个下标可以通过2.py获取已加载到的下标)
54.     for data in islice(DATA, 4849, None):
55.         print(data)
57.         try:
58.             roomid = data["roomid"]
59.         except (KeyError, TypeError, IndexError) as e:
60.             print(e)
61.             continue
63.         if roomid == 0:
64.             continue
66.         # 睡眠个0.5s
67.         await asyncio.sleep(0.5)
68.         json1 = await get_medal(roomid)
69.         # print(json1)
70.         try:
71.             if json1["code"] != 0:
72.                 print(json1)
73.                 continue
75.             # 获取牌子名
76.             medal_name = str(json1["data"]["medal"]["up_medal"]["medal_name"])
77.             # 拼接新的json串
78.             temp_json = { medal_name: data }
79.             try:
80.                 # 判断是否已经存在
81.                 if temp_json in DATA_MEDAL:
82.                     print("已存在 " + medal_name + " 跳过")
83.                     continue
84.                 else:
85.                     # 追加入json
86.                     data_medal_json.append(temp_json)
87.             except (KeyError, TypeError, IndexError) as e:
88.                 print(e)
89.                 continue
90.             # 计数+1
91.             num += 1
92.             print("获取牌子名：" + medal_name)
94.             # 每获取10个结果 写入一次数据文件
95.             if num % 10 == 0 and num != 0:
96.                 filename = 'data_medal.py'
97.                 with open(filename, 'w', encoding="utf-8") as file_object:
98.                     file_object.write("DATA_MEDAL = " + json.dumps(data_medal_json, ensure_ascii=False))
99.                 file_object.close()
100.                 print("num=" + str(num) + ", 写入" + filename)
101.         except (KeyError, TypeError, IndexError) as e:
102.             print(e)
103.             continue
105.     filename = 'data_medal.py'
106.     with open(filename, 'w', encoding="utf-8") as file_object:
107.         file_object.write("DATA_MEDAL = " + json.dumps(data_medal_json, ensure_ascii=False))
108.     file_object.close()
109.     print("num=" + str(num) + ", 写入" + filename)
110.     print("数据爬取完毕了，收工回家~")
113. if __name__ == "__main__":
114.     asyncio.run(main())

复制代码

来源:https://www.cnblogs.com/ikaros-521/p/17083274.html
免责声明：由于采集信息均来自互联网，如果侵犯了您的权益，请联系我们【E-Mail:cb@itdo.tech】 我们会及时删除侵权内容，谢谢合作！