forked from Ikaros-521/AI-Vtuber
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
ebbd9b0
commit 63e7d69
Showing
6 changed files
with
126 additions
and
13 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,76 @@ | ||
# -*- coding: utf-8 -*- | ||
import asyncio | ||
|
||
import blivedm | ||
import blivedm.models.open_live as open_models | ||
import blivedm.models.web as web_models | ||
|
||
# 在开放平台申请的开发者密钥 | ||
ACCESS_KEY_ID = '' | ||
ACCESS_KEY_SECRET = '' | ||
# 在开放平台创建的项目ID | ||
APP_ID = 0 | ||
# 主播身份码 | ||
ROOM_OWNER_AUTH_CODE = '' | ||
|
||
|
||
async def main(): | ||
await run_single_client() | ||
|
||
|
||
async def run_single_client(): | ||
""" | ||
演示监听一个直播间 | ||
""" | ||
client = blivedm.OpenLiveClient( | ||
access_key_id=ACCESS_KEY_ID, | ||
access_key_secret=ACCESS_KEY_SECRET, | ||
app_id=APP_ID, | ||
room_owner_auth_code=ROOM_OWNER_AUTH_CODE, | ||
) | ||
handler = MyHandler() | ||
client.set_handler(handler) | ||
|
||
client.start() | ||
try: | ||
# 演示70秒后停止 | ||
# await asyncio.sleep(70) | ||
# client.stop() | ||
|
||
await client.join() | ||
finally: | ||
await client.stop_and_close() | ||
|
||
|
||
class MyHandler(blivedm.BaseHandler): | ||
def _on_heartbeat(self, client: blivedm.BLiveClient, message: web_models.HeartbeatMessage): | ||
print(f'[{client.room_id}] 心跳') | ||
|
||
def _on_open_live_danmaku(self, client: blivedm.OpenLiveClient, message: open_models.DanmakuMessage): | ||
print(f'[{message.room_id}] {message.uname}:{message.msg}') | ||
|
||
def _on_open_live_gift(self, client: blivedm.OpenLiveClient, message: open_models.GiftMessage): | ||
coin_type = '金瓜子' if message.paid else '银瓜子' | ||
total_coin = message.price * message.gift_num | ||
print(f'[{message.room_id}] {message.uname} 赠送{message.gift_name}x{message.gift_num}' | ||
f' ({coin_type}x{total_coin})') | ||
|
||
def _on_open_live_buy_guard(self, client: blivedm.OpenLiveClient, message: open_models.GuardBuyMessage): | ||
print(f'[{message.room_id}] {message.user_info.uname} 购买 大航海等级={message.guard_level}') | ||
|
||
def _on_open_live_super_chat( | ||
self, client: blivedm.OpenLiveClient, message: open_models.SuperChatMessage | ||
): | ||
print(f'[{message.room_id}] 醒目留言 ¥{message.rmb} {message.uname}:{message.message}') | ||
|
||
def _on_open_live_super_chat_delete( | ||
self, client: blivedm.OpenLiveClient, message: open_models.SuperChatDeleteMessage | ||
): | ||
print(f'[{message.room_id}] 删除醒目留言 message_ids={message.message_ids}') | ||
|
||
def _on_open_live_like(self, client: blivedm.OpenLiveClient, message: open_models.LikeMessage): | ||
print(f'[{message.room_id}] {message.uname} 点赞') | ||
|
||
|
||
if __name__ == '__main__': | ||
asyncio.run(main()) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters