示例：获取直播间弹幕和礼物

  1. from bilibili_api import live, sync
  3. room = live.LiveDanmaku(22544798)
  5. @room.on('DANMU_MSG')
  6. async def on_danmaku(event):
  7.     # 收到弹幕
  8.     print(event)
  10. @room.on('SEND_GIFT')
  11. async def on_gift(event):
  12.     # 收到礼物
  13.     print(event)
  15. sync(room.connect())

示例：简易录播

  1. from bilibili_api import live, sync
  2. import aiohttp
  5. async def main():
  6.     # 初始化
  7.     room = live.LiveRoom(3)
  8.     # 获取直播流链接
  9.     stream_info = await room.get_room_play_url()
  10.     url = stream_info['durl'][0]['url']
  12.     async with aiohttp.ClientSession() as sess:
  13.         # 设置 UA 和 Referer 头以绕过验证
  14.         async with sess.get(url, headers={"User-Agent": "Mozilla/5.0", "Referer": "https://www.bilibili.com/"}) as resp:
  15.             # 以二进制追加方式打开文件以存储直播流
  16.             with open('live.flv', 'ab') as f:
  17.                 while True:
  18.                     # 循环读取最高不超过 1024B 的数据
  19.                     chunk = await resp.content.read(1024)
  20.                     if not chunk:
  21.                         # 无更多数据，退出循环
  22.                         print('无更多数据')
  23.                         break
  24.                     print(f'接收到数据 {len(chunk)}B')
  25.                     # 写入数据
  26.                     f.write(chunk)
  28. sync(main())

示例：直播间赠送金瓜子礼物

  1. from bilibili_api import live, sync, Credential
  3. SESSDATA = ""
  4. BILI_JCT = ""
  5. BUVID3 = ""
  7. # 自己的uid
  8. self_uid = 0
  9. # 实例化 Credential 类
  10. credential = Credential(sessdata=SESSDATA, bili_jct=BILI_JCT, buvid3=BUVID3)
  11. room = live.LiveRoom(22544798, credential)
  13. # 获取礼物列表
  14. gift_config = sync(live.get_gift_config())
  15. for gift in gift_config['list']:
  16.     if gift['name'] == "牛哇牛哇":
  17.         # 赠送礼物 "牛哇牛哇" 1个
  18.         res = sync(room.send_gift_gold(uid=self_uid, gift_id=gift['id'], gift_num=1, price=gift['price']))
  19.         print(res)
  20.         break
  21. else:
  22.     print('礼物 牛哇牛哇 不存在')