update

toolbox/bilibili/video/video_manager.py

@@ -119,7 +119,7 @@ class BilibiliVideoUploader(BilibiliClient):
             "total": filesize,
         }
 
-        process_bar = tqdm("bilibili_upload_video", total=chunks)
+        process_bar = tqdm(desc="bilibili_upload_video", total=chunks)
         for chunknum in range(chunks):
             start = fileio.tell()
             batchbytes = fileio.read(chunk_size)
@@ -136,7 +136,7 @@ class BilibiliVideoUploader(BilibiliClient):
             )
             if response.status_code != 200:
                 raise AssertionError(f"request failed; status_code: {response.status_code}, text: {response.text}")
-            process_bar.update(1)
+            process_bar.update(n=1)
 
     @retry(
         wait=wait_fixed(10),

toolbox/porter/tasks/douyin_live_record_task.py

@@ -74,13 +74,12 @@ class DouyinLiveRecordTask(BaseTask):
     def get_video_info(self, title):
         tz = ZoneInfo("Asia/Shanghai")
         now = datetime.now(tz)
-        create_time_str = now.strftime("%Y%m%d_%H%M%S")
-        # create_time_str = time.strftime("%Y%m%d_%H%M%S")
-        video_id = create_time_str
+        create_time_str = now.strftime("%Y%m%dT%H%M%S")
+        video_id = now.strftime("%Y%m%d_%H%M%S")
         title = f"{title}({video_id}直播)"
         tags = ["Douyin", self.room_name]
         filename = self.output_video_dir / f"{title[:50]}.flv"
-        return create_time_str, filename, title, tags, video_id
+        return create_time_str, filename.as_posix(), title, tags, video_id
 
     def get_streamlink_session(self):
         session = streamlink.session.Streamlink({
@@ -244,7 +243,7 @@ class DouyinLiveRecordTask(BaseTask):
             "title": title,
             "desc": "",
             "tags": tags,
-            "url_list": ["live_url"],
+            "url_list": [live_url],
 
             "video_id": video_id,
         }

toolbox/porter/tasks/video_to_bilibili_task.py

@@ -137,7 +137,8 @@ class VideoToBilibiliTask(BaseTask):
                     continue
                 logger.info(f"{self.flag}上传视频：{filename}")
                 video_id = await asyncio.to_thread(
-                    self.bilibili_video_manager.upload_video_draft_and_publish,
+                    # self.bilibili_video_manager.upload_video_draft_and_publish,
+                    self.bilibili_video_manager.upload_video_and_publish,
                     filename=filename,
                     metadata=metadata,
                 )

toolbox/porter/tasks/video_to_youtube_task.py

@@ -51,7 +51,7 @@ class VideoToYoutubeTask(BaseTask):
                  check_interval: int,
                  video_info_file: str,
                  remove_after_upload: bool = False,
-                 remove_after_upload_delay: float = 3600,
+                 remove_after_upload_delay: float = 0.1,
                  playlist_title: str = None,
                  playlist_id: str = None,
                  min_date: str = None,