示例：获取剧情图所有节点

用途：下载所有节点视频信息、获取剧情图结构。

需要一定水平才能看懂。

  1. from bilibili_api import interactive_video, sync
  2. import json
  4. BVID = 'BV1Dt411N7LY'
  6. async def main():
  7.     # 获取剧情图版本号
  8.     graph_version = await interactive_video.get_graph_version(BVID)
  10.     # 存储顶点信息
  11.     edges_info = {}
  13.     # 使用队列来遍历剧情图，初始为 None 是为了从初始顶点开始
  14.     queue = [None]
  16.     def createEdge(edge_id: int):
  17.         """
  18.         创建节点信息到 edges_info
  19.         """
  20.         edges_info[edge_id] = {
  21.             "title": None,
  22.             "cid": None,
  23.             "option": None
  24.         }
  26.     while queue:
  27.         # 出队
  28.         edge_id = queue.pop()
  30.         if edge_id in edges_info and edges_info[edge_id]['title'] is not None and edges_info[edge_id]['cid'] is not None:
  31.             # 该情况为已获取到所有信息，说明是跳转到之前已处理的顶点，不作处理
  32.             continue
  34.         # 获取顶点信息，最大重试 3 次
  35.         retry = 3
  36.         while True:
  37.             try:
  38.                 node = await interactive_video.get_edge_info(BVID, graph_version, edge_id)
  40.                 # 打印当前顶点信息
  41.                 print(node['edge_id'], node['title'])
  42.                 break
  43.             except Exception as e:
  44.                 retry -= 1
  45.                 if retry < 0:
  46.                     raise e
  48.         # 检查节顶点是否在 edges_info 中，本次步骤得到 title 信息
  49.         if node['edge_id'] not in edges_info:
  50.             # 不在，新建
  51.             createEdge(node['edge_id'])
  53.         # 设置 title
  54.         edges_info[node['edge_id']]['title'] = node['title']
  56.         # 起始顶点，需要用额外技巧获得 cid
  57.         if edge_id is None:
  58.             for s in node['story_list']:
  59.                 if s['edge_id'] == 1:
  60.                     edges_info[node['edge_id']]['cid'] = s['cid']
  62.         # 无可达顶点，即不能再往下走了，类似树的叶子节点
  63.         if 'questions' not in node['edges']:
  64.             continue
  66.         # 遍历所有可达顶点
  67.         for q in node['edges']['questions']:
  68.             for c in q['choices']:
  69.                 # 该步骤获取顶点的 cid（视频分 P 的 ID）
  70.                 if c['id'] not in edges_info:
  71.                     createEdge(c['id'])
  73.                 edges_info[c['id']]['cid'] = c['cid']
  74.                 edges_info[c['id']]['option'] = c['option']
  76.                 # 所有可达顶点 ID 入队
  77.                 queue.insert(0, c['id'])
  79.     print(json.dumps(edges_info, indent=2, ensure_ascii=False))
  81. sync(main())

示例：提交情节图

  • best_story.py
  1. from bilibili_storytree import StoryGraph, ScriptNode
  3. class Oscar:
  4.   def __init__(self, videos: dict, aid: int):
  5.     self.videos = videos
  6.     # Create graph
  7.     self.graph = StoryGraph(aid=aid)
  9.   def gen_simple_graph(self, root_title: str):
  10.     # 建情节树：只有一个分支剧情模块
  11.     root_video = self.videos[root_title] 
  12.     n_root = ScriptNode(node_type="videoNode", isRoot=True)
  13.     n_root.set_video(video=root_video)
  14.     self.graph._update_script_nodes([n_root]) # update graph["script"]["nodes"]
  15.     self.graph._sync_nodes() # create graph["nodes"]
  16.     self.graph._sync_vars() # create graph["regional_vars"]
  • ivideo_submit.py
  1. import os
  2. import asyncio
  3. from bilibili_api import video, interactive_video, Credential
  4. import re
  5. from best_story import Oscar
  6. import json
  7. import time
  9. SESSDATA = "记得填" 
  10. BILI_JCT = "记得填"
  11. BUVID3 = "记得填"
  13. def reform_videos(videos):
  14.   video_objs = {}
  15.   for v in videos:
  16.     video_objs[v["title"]] = v 
  17.   return video_objs
  19. async def save_tree(bvid):
  20.   # 实例化 Credential 类
  21.   credential = Credential(sessdata=SESSDATA, bili_jct=BILI_JCT, buvid3=BUVID3)
  24.   # 查询交互视频信息
  25.   info = await interactive_video.up_get_ivideo_pages(bvid=bvid, credential=credential)
  26.   vobjs = reform_videos(info["videos"])
  27.   aid = info["videos"][0]["aid"]
  29.   # 自定义一个情节树
  30.   g = Oscar(videos=vobjs, aid=aid)
  31.   g.gen_simple_graph(root_title="root") # 记得改 pick one video title 
  32.   g.graph.pretty_print()
  33.   story = json.dumps({"graph": g.graph._serialize()})
  34.   #print(story)
  36.   # 上传情节树
  37.   graph_result = await interactive_video.up_submit_story_tree(story_tree=story, credential=credential)
  38.   return graph_result
  41. UPLOAD_CONFIG = {
  42.   "copyright": 1, #"1 自制，2 转载。",
  43.   "source": "", #"str, 视频来源。投稿类型为转载时注明来源，为原创时为空。",
  44.   "desc": "", #"str, 视频简介。",
  45.   "desc_format_id": 0,
  46.   "dynamic": "", #"str, 动态信息。",
  47.   "interactive": 1,
  48.   "open_elec": 0, #"int, 是否展示充电信息。1 为是，0 为否。",
  49.   "no_reprint": 1, #"int, 显示未经作者授权禁止转载，仅当为原创视频时有效。1 为启用，0 为关闭。",
  50.   "subtitles": {
  51.     "lan": "", #"字幕语言，不清楚作用请将该项设置为空",
  52.     "open": 0
  53.   },
  54.   "tag": "学习,测试", #"str, 视频标签。使用英文半角逗号分隔的标签组。示例：标签1,标签2,标签3",
  55.   "tid": 208, #"int, 分区ID。可以使用 channel 模块进行查询。",
  56.   #"title": "jump jump jump", #"视频标题",
  57.   "up_close_danmaku": False, #"bool, 是否关闭弹幕。",
  58.   "up_close_reply": False, #"bool, 是否关闭评论。",
  59. }
  61. async def upload_videos(video_dir, cover_img, title):
  62.   # 上传多P视频到互动视频
  63.   cover = open(cover_img, "r+b")
  65.   videos = []
  66.   for filename in os.listdir(video_dir):
  67.     if filename.endswith(".mp4"): 
  68.       video_file = os.path.join(video_dir, filename)
  69.       print(video_file)
  70.       videos.append(video.VideoUploaderPageObject(video_stream=open(video_file, "r+b"), title=filename.split(".")[0]))
  72.   config = UPLOAD_CONFIG
  73.   config["title"] = title
  75.   credential = Credential(sessdata=SESSDATA, bili_jct=BILI_JCT, buvid3=BUVID3)
  77.   uploader = video.VideoUploader(cover=cover, cover_type="jpg", pages=videos, config=config, credential=credential) 
  79.   info =  await uploader.start()
  81.   return info
  83. if __name__ == '__main__':
  84.   folder = "directory contains video files" # 记得填
  85.   img = "image file path" # 记得填
  86.   title = "interactive video name" # 记得填
  88.   info = asyncio.get_event_loop().run_until_complete(upload_videos(folder, img, title))
  89.   print(info) # {"bvid": "ssssss", "aid": ddddddd}
  90.   bvid = info["bvid"]
  91.   time.sleep(120) # 为了 B 站视频编码的时间, 躺平 2 分钟
  92.   graph_result = asyncio.get_event_loop().run_until_complete(save_tree(bvid))
  93.   print(graph_result) # 成功之后，编辑树会延迟，不超过5分钟。 如果觉得有问题，就在执行一次上个存树的命令, 这时多半立即执行，推测是队列机制。