diff --git a/liveMan.py b/liveMan.py index 4bd508a..6bce832 100644 --- a/liveMan.py +++ b/liveMan.py @@ -334,7 +334,7 @@ class DouyinLiveWebFetcher: asyncio.run(send_message(f"【点赞msg】{user_name} 点了{count}个赞")) - async def _parseMemberMsg(self, payload): + def _parseMemberMsg(self, payload): '''进入直播间消息''' message = MemberMessage().parse(payload) user_name = message.user.nick_name @@ -358,7 +358,7 @@ class DouyinLiveWebFetcher: current = message.total total = message.total_pv_for_anchor print(f"【统计msg】当前观看人数: {current}, 累计观看人数: {total}") - asyncio.run(send_message(f"【统计msg】当前观看人数: {current}, 累计观看人数: {total}")) + # asyncio.run(send_message(f"【统计msg】当前观看人数: {current}, 累计观看人数: {total}")) def _parseFansclubMsg(self, payload): @@ -385,22 +385,21 @@ class DouyinLiveWebFetcher: common = message.common room_id = common.room_id print(f"【直播间msg】直播间id:{room_id}") - asyncio.run(send_message(f"【直播间msg】直播间id:{room_id}")) + # asyncio.run(send_message(f"【直播间msg】直播间id:{room_id}")) def _parseRoomStatsMsg(self, payload): message = RoomStatsMessage().parse(payload) display_long = message.display_long print(f"【直播间统计msg】{display_long}") - asyncio.run(send_message(f"【直播间统计msg】{display_long}")) + # asyncio.run(send_message(f"【直播间统计msg】{display_long}")) def _parseRankMsg(self, payload): message = RoomRankMessage().parse(payload) ranks_list = message.ranks_list print(f"【直播间排行榜msg】{ranks_list}") - asyncio.run(send_message(f"【直播间排行榜msg】{ranks_list}")) - + # asyncio.run(send_message(f"【直播间排行榜msg】{ranks_list}")) def _parseControlMsg(self, payload): '''直播间状态消息''' @@ -408,12 +407,12 @@ class DouyinLiveWebFetcher: if message.status == 3: print("直播间已结束") - asyncio.run(send_message(f"直播间已结束")) + # asyncio.run(send_message(f"直播间已结束")) self.stop() def _parseRoomStreamAdaptationMsg(self, payload): message = RoomStreamAdaptationMessage().parse(payload) adaptationType = message.adaptation_type print(f'直播间adaptation: {adaptationType}') - asyncio.run(send_message(f'直播间adaptation: {adaptationType}')) + # asyncio.run(send_message(f'直播间adaptation: {adaptationType}')) diff --git a/main.py b/main.py index 71e4674..d4e7541 100644 --- a/main.py +++ b/main.py @@ -6,7 +6,7 @@ import asyncio from ws_server import start_ws_server if __name__ == '__main__': - live_id = '139226983757' + live_id = '174880838400' room = DouyinLiveWebFetcher(live_id) room.get_room_status() room.start()