快手直播间爬虫可获取礼物

快手直播数据爬虫
有时候获取接口会更新，需要重新抓包

cursor = conn.cursor()
def getSig(param, body, salt='382700b563f4'):params = param.copy()params.update(body)keys = list(params.keys())keys.sort()temp_str = ''for key in keys:temp_str = temp_str + key.strip() + '=' + params[key].strip()# return get(temp_str)sig = temp_str + saltm = hashlib.md5()m.update(sig.encode(encoding='utf-8'))str_md5 = m.hexdigest()return str_md5def get_live_stream_id(user_id):user_id = str(user_id)if not user_id.isdigit():uri1 = 'http://gifshow.3agzs.com/rest/n/user/search?&token=0-0&count=10&user_name=' + user_idres = requests.get(uri1)try:user_id = res.json()['users'][0]['user_id']except IndexError:raise Exception("请检查主播id是否正常")uri = "https://live.gifshow.com/rest/n/live/startPlay/v2"def __hello(self):d_204 = base64.b64decode("ARorPAAAAAAAAAAAAAAATQjMARABGkYKC1l5R2xUWE9wYkR3GOq6m4wFUAJaGEFORFJPSURfZDdjYmVmMGU5MjAyM2NhOGIFemhfQ05qBzEuMS4xLjWCAQRXSUZJ".encode())self.send_msg(d_204)def __enter_live(self):d_200 = self.EncodeVarint(self.newRoom())self.send_msg(d_200)def __prepare(self):# 与服务器相应self.__hello()# 进入直播间self.__enter_live()# 发送第一次心跳self.__send_hearbeat()def start(self):self.live_stream_id = get_live_stream_id(self.k_id)self.sock.connect((self.host, self.port))# 连接前的准备self.__prepare()send_hearbeat_time = time.time()print('start .... ')while True:# 二十秒发送一次心跳数据包if time.time() - send_hearbeat_time > 20:self.__send_hearbeat()send_hearbeat_time = time.time()data = self.sock.recv(10240)recv_data = self.DecodeVarint(data)proto = live_pb2.SocketMessages()proto.ParseFromString(recv_data)content = proto.contenttry:content = gzip.decompress(content)except:pass

处理消息

scf:= livestream.scf{}
ps.Unmarshal(undata, &scf)

if len(scf.cmf) == 1 && scf.cmf[0].Id == “” {
fmt.Printf("— %s —直播间观看人数 %s 点赞人数 %s \n",scf.mcf[0].User.UserName, scf.dlwc, scf.dlc)

}else {
for i,v := range scf.cmf{
_, _ = fmt.Printf("%s --消息 --%d – %s >> %s \n",TagMap[newProto.Tag], i, v.User.UserName, v.Content)
}
for i,v := range scf.lif{
_, _ = fmt.Printf("%s --喜欢 – %d – %s \n",TagMap[newProto.Tag], i, v.User.UserName)
}
//fmt.Println(“礼物”)
for i,v := range scf.gfe{
_, _ = fmt.Printf("%s --礼物 --%d – %s >> %d \n",TagMap[newProto.Tag], i, v.User.UserName, v.GiftId)
}
//fmt.Println(“分享”)
for i,v := range scf.shf{
_, _ = fmt.Printf("%s --分享 --%d – %s \n",TagMap[newProto.Tag], i, v.User.UserName)
}
//fmt.Println(“关注”)
for i,v := range scf.fath{
_, _ = fmt.Printf("%s --关注 --%d – %s \n",TagMap[newProto.Tag], i, v.Fans.UserName)
}
for i,v := range scf.pcsh{
_, _ = fmt.Printf("%s --购买 --%d – %s %s %s \n",TagMap[newProto.Tag], i, v.User.UserName, v.CommodityName, v.JumpToken)
}

for i,v := range scf.etrf{_, _ = fmt.Printf("%s --新观众 --%d -- %s %d %s \n",TagMap[newProto.Tag], i, v.User.UserName, v.Laiyuan)
}

}
演示效果
分别可以解析到

直播弹幕、礼物、新进入房间的观众和来源、双击点心、分析直播、

带货主播有某个观众购买了什么商品

有意向可以联系QQ 469864288

快手直播间爬虫可获取礼物相关推荐

快手直播间数据采集截流软件脚本,实时采集引流精准获取客源【采集脚本+引流技术教程】
脚本功能:可查观众的块手号,二维码,主页,实时的弹幕消息,以及直播间送出的礼物,实时切换榜首的信息. 设备需求:电脑文章的来源:ZZZZ.LA 文章分享者:Linxiaoyu2022 文章的来源: ...
快手直播间实时弹幕发言API
请求地址 HTTPGET https://www.youwk.cn/api/dm/kuaishou 请求参数参数名参数说明 key 用户请求密钥,可在密钥管理页面申请 id 快手直播间live ...
如何获取抖音和快手直播间的直播流地址
如下是通过python代码脚本获取的方法: import requests import re def get_real_url(rid): try: if 'v.douyin.com' in rid ...
直播间留不住观众？3个技巧教你提高快手直播间留存率
观众在直播间停留的时长是决定直播成效和粉丝转化的重要因素之一,现在很多大小主播的直播间已经不是单纯的卖产品了,除了带货还会额外增加一些娱乐.互动环节,目的就是为了能够留住观众,方便后续的带货转化. 用 ...
快手直播间显示服务器繁忙,高颜值、高学历、一年直播365天，陌陌顶级主播的日常...
声明:本文来自于微信公众号科技唆麻(ID:techsuoma),作者:科技唆麻,授权站长之家转载发布. 纪伯伦认为,理想和成就无法被直接划上等号,「它取决于一个人的热情能否支持自己跨越中间的鸿沟.」 ...
快手直播间如何引流？快手直播推广怎么玩？
快手是一个超好玩的短视频社区,每时每刻都有来自世界各地的小伙伴在这里分享自己制作的短视频.现在的快手不仅可以制造短视频,还拥有了直播的功能,那么快手直播效果好吗? 快手直播效果好吗? 快手发展优势日益 ...
淘宝直播间推流码获取
1.打开海鹰直播抓取器 2.千牛后台开启直播预告 3.打开淘宝直播软件 4.登录淘宝账号并前往中控台发布直播 5.选择好对应的直播场次后点击确定 6.若此时电商直播助手里还未获取到推流码,可点击淘宝直 ...
android实现抖音直播间飘屏送礼物动画（超简单）
没有效果图的示例简直就是扯淡飘屏动画直接上代码吧自定义view:ShowNewLuckyMsgView.class package com.chushou.demo2;import androi ...
快手在直播间里养起了AI宠物，连柳岩、大鹏都爱不释手
郭一璞发自凹非寺量子位报道 | 公众号 QbitAI 昨天下午,柳岩和大鹏到快手总部"扫楼","快手星闻"全程直播.一个吸引人的橙色小精灵,全程活跃在直 ...

快手直播间爬虫可获取礼物

快手直播间爬虫可获取礼物相关推荐

最新文章

热门文章