update

data/porter_tasks/porter_task_chenjieshen_douyin_live_record_to_youtube.json

@@ -4,6 +4,7 @@
     "type": "douyin_live_record",
     "room_name": "老陈的退路",
     "room_id": "330025930592",
+    "sec_user_id": "MS4wLjABAAAAzjLy7Dd3Q-UiMGdkwymLhDIL1aFJtruvCUqrwmph9n8Zb55E4y9XH2WEFaLC1ZBl",
     "key_of_credentials": "douyin_wentao_credentials",
     "check_interval": 10,
     "output_video_dir": "data/tasks/chenjieshen_douyin_live_record_to_youtube/live_record/陈杰森",
@@ -14,6 +15,7 @@
     "type": "douyin_live_record",
     "room_name": "老陈come_back",
     "room_id": "78835697536",
+    "sec_user_id": "MS4wLjABAAAAj3qTpPkes0t5az2nXd1oaag5TpOJeNh27pemT17WUVXHGUZKZfjqc3fFc8arL6V1",
     "key_of_credentials": "douyin_wentao_credentials",
     "check_interval": 10,
     "output_video_dir": "data/tasks/chenjieshen_douyin_live_record_to_youtube/live_record/陈杰森",
@@ -24,6 +26,7 @@
     "type": "douyin_live_record",
     "room_name": "清源第一帅",
     "room_id": "654177813521",
+    "sec_user_id": "MS4wLjABAAAAtwkRNs5Krtm5cBhKzn60poflAFWdnYdwMf0I0M27rOGvNn2l16DfUH5vE3WL-ypz",
     "key_of_credentials": "douyin_wentao_credentials",
     "check_interval": 10,
     "output_video_dir": "data/tasks/chenjieshen_douyin_live_record_to_youtube/live_record/陈杰森",
@@ -34,6 +37,7 @@
     "type": "douyin_live_record",
     "room_name": "清源第二帅",
     "room_id": "831568261978",
+    "sec_user_id": "MS4wLjABAAAALbRezHNzlaRYhk9QE-5ajImgcvfJGq9koAlD0O8VQwiC-N8Bqx2WDW07wLee2Bwd",
     "key_of_credentials": "douyin_wentao_credentials",
     "check_interval": 10,
     "output_video_dir": "data/tasks/chenjieshen_douyin_live_record_to_youtube/live_record/陈杰森",
@@ -44,6 +48,7 @@
     "type": "douyin_live_record",
     "room_name": "清源第三帅",
     "room_id": "26569028431",
+    "sec_user_id": "MS4wLjABAAAA60pV9JuZNTZhQJeSI_AeaRUnKXs--TGPZEAtsgihwKnir46ncFVtLSO79JDnclkM",
     "key_of_credentials": "douyin_wentao_credentials",
     "check_interval": 10,
     "output_video_dir": "data/tasks/chenjieshen_douyin_live_record_to_youtube/live_record/陈杰森",
@@ -54,6 +59,7 @@
     "type": "douyin_live_record",
     "room_name": "清源人工智能研究院",
     "room_id": "81728900292",
+    "sec_user_id": "MS4wLjABAAAAe_Hf6esmopqIMG7OhsMlNESTiqP1ot7lmGzK6Cu3pJSSGTOiHlI4cA33OPWg56Ql",
     "key_of_credentials": "douyin_wentao_credentials",
     "check_interval": 10,
     "output_video_dir": "data/tasks/chenjieshen_douyin_live_record_to_youtube/live_record/陈杰森",
@@ -64,6 +70,7 @@
     "type": "douyin_live_record",
     "room_name": "小熊Bella与老爸",
     "room_id": "139751520143",
+    "sec_user_id": "MS4wLjABAAAA49QFP6YhorLIIX9M-FiZeKxmqhqXlttluSsZeaxvxzU",
     "key_of_credentials": "douyin_wentao_credentials",
     "check_interval": 10,
     "output_video_dir": "data/tasks/chenjieshen_douyin_live_record_to_youtube/live_record/陈杰森",
@@ -74,6 +81,7 @@
     "type": "douyin_live_record",
     "room_name": "清源之虎",
     "room_id": "998621457719",
+    "sec_user_id": "MS4wLjABAAAAWYFqu46IMCnfwgSjBK35RnQcKOYhqVX3YcP4rotpHkdxJn5JD59REMz5fwlccp2h",
     "key_of_credentials": "douyin_wentao_credentials",
     "check_interval": 10,
     "output_video_dir": "data/tasks/chenjieshen_douyin_live_record_to_youtube/live_record/陈杰森",
@@ -84,6 +92,7 @@
     "type": "douyin_live_record",
     "room_name": "老陈真是好人",
     "room_id": "599130203190",
+    "sec_user_id": "MS4wLjABAAAA3ReegyjpprzeurqHUl8yLBkTlQ7L4TfoyjpDXeiy1RvCu7OmqWljOLmWgibTjs8y",
     "key_of_credentials": "douyin_wentao_credentials",
     "check_interval": 10,
     "output_video_dir": "data/tasks/chenjieshen_douyin_live_record_to_youtube/live_record/陈杰森",
@@ -94,6 +103,7 @@
     "type": "douyin_live_record",
     "room_name": "老陈小帮手",
     "room_id": "738682070097",
+    "sec_user_id": "MS4wLjABAAAAtzZsG1mKtZvgE2j58ZB7FDRP1gzsHXuQDIN15bltkLM",
     "key_of_credentials": "douyin_wentao_credentials",
     "check_interval": 10,
     "output_video_dir": "data/tasks/chenjieshen_douyin_live_record_to_youtube/live_record/陈杰森",

data/porter_tasks/porter_task_chenjieshen_douyin_live_to_bilibili_live.json

@@ -4,6 +4,7 @@
     "type": "douyin_live_to_bilibili_live",
     "room_name": "老陈的退路",
     "room_id": "330025930592",
+    "sec_user_id": "MS4wLjABAAAAzjLy7Dd3Q-UiMGdkwymLhDIL1aFJtruvCUqrwmph9n8Zb55E4y9XH2WEFaLC1ZBl",
     "check_interval": 10,
     "key_of_douyin_credentials": "douyin_wentao_credentials",
     "key_of_bilibili_credentials": "bilibili_chenjiesen_credentials"
@@ -13,6 +14,7 @@
     "type": "douyin_live_to_bilibili_live",
     "room_name": "老陈come_back",
     "room_id": "78835697536",
+    "sec_user_id": "MS4wLjABAAAAj3qTpPkes0t5az2nXd1oaag5TpOJeNh27pemT17WUVXHGUZKZfjqc3fFc8arL6V1",
     "check_interval": 10,
     "key_of_douyin_credentials": "douyin_wentao_credentials",
     "key_of_bilibili_credentials": "bilibili_chenjiesen_credentials"
@@ -22,6 +24,7 @@
     "type": "douyin_live_to_bilibili_live",
     "room_name": "清源第一帅",
     "room_id": "654177813521",
+    "sec_user_id": "MS4wLjABAAAAtwkRNs5Krtm5cBhKzn60poflAFWdnYdwMf0I0M27rOGvNn2l16DfUH5vE3WL-ypz",
     "check_interval": 10,
     "key_of_douyin_credentials": "douyin_wentao_credentials",
     "key_of_bilibili_credentials": "bilibili_chenjiesen_credentials"
@@ -31,6 +34,7 @@
     "type": "douyin_live_to_bilibili_live",
     "room_name": "清源第二帅",
     "room_id": "831568261978",
+    "sec_user_id": "MS4wLjABAAAALbRezHNzlaRYhk9QE-5ajImgcvfJGq9koAlD0O8VQwiC-N8Bqx2WDW07wLee2Bwd",
     "check_interval": 10,
     "key_of_douyin_credentials": "douyin_wentao_credentials",
     "key_of_bilibili_credentials": "bilibili_chenjiesen_credentials"
@@ -40,6 +44,7 @@
     "type": "douyin_live_to_bilibili_live",
     "room_name": "清源第三帅",
     "room_id": "26569028431",
+    "sec_user_id": "MS4wLjABAAAA60pV9JuZNTZhQJeSI_AeaRUnKXs--TGPZEAtsgihwKnir46ncFVtLSO79JDnclkM",
     "check_interval": 10,
     "key_of_douyin_credentials": "douyin_wentao_credentials",
     "key_of_bilibili_credentials": "bilibili_chenjiesen_credentials"
@@ -49,6 +54,7 @@
     "type": "douyin_live_to_bilibili_live",
     "room_name": "清源人工智能研究院",
     "room_id": "81728900292",
+    "sec_user_id": "MS4wLjABAAAAe_Hf6esmopqIMG7OhsMlNESTiqP1ot7lmGzK6Cu3pJSSGTOiHlI4cA33OPWg56Ql",
     "check_interval": 10,
     "key_of_douyin_credentials": "douyin_wentao_credentials",
     "key_of_bilibili_credentials": "bilibili_chenjiesen_credentials"
@@ -58,6 +64,7 @@
     "type": "douyin_live_to_bilibili_live",
     "room_name": "小熊Bella与老爸",
     "room_id": "139751520143",
+    "sec_user_id": "MS4wLjABAAAA49QFP6YhorLIIX9M-FiZeKxmqhqXlttluSsZeaxvxzU",
     "check_interval": 10,
     "key_of_douyin_credentials": "douyin_wentao_credentials",
     "key_of_bilibili_credentials": "bilibili_chenjiesen_credentials"
@@ -67,6 +74,7 @@
     "type": "douyin_live_to_bilibili_live",
     "room_name": "清源之虎",
     "room_id": "998621457719",
+    "sec_user_id": "MS4wLjABAAAAWYFqu46IMCnfwgSjBK35RnQcKOYhqVX3YcP4rotpHkdxJn5JD59REMz5fwlccp2h",
     "check_interval": 10,
     "key_of_douyin_credentials": "douyin_wentao_credentials",
     "key_of_bilibili_credentials": "bilibili_chenjiesen_credentials"
@@ -76,6 +84,7 @@
     "type": "douyin_live_to_bilibili_live",
     "room_name": "老陈真是好人",
     "room_id": "599130203190",
+    "sec_user_id": "MS4wLjABAAAA3ReegyjpprzeurqHUl8yLBkTlQ7L4TfoyjpDXeiy1RvCu7OmqWljOLmWgibTjs8y",
     "check_interval": 10,
     "key_of_douyin_credentials": "douyin_wentao_credentials",
     "key_of_bilibili_credentials": "bilibili_chenjiesen_credentials"
@@ -85,6 +94,7 @@
     "type": "douyin_live_to_bilibili_live",
     "room_name": "老陈小帮手",
     "room_id": "738682070097",
+    "sec_user_id": "MS4wLjABAAAAtzZsG1mKtZvgE2j58ZB7FDRP1gzsHXuQDIN15bltkLM",
     "check_interval": 10,
     "key_of_douyin_credentials": "douyin_wentao_credentials",
     "key_of_bilibili_credentials": "bilibili_chenjiesen_credentials"

data/porter_tasks/porter_task_chenjieshen_douyin_video_to_bilibili.json

@@ -6,7 +6,7 @@
     "sec_user_id": "MS4wLjABAAAATGoBrO7yiJ3q9go4fxq9JXjrnP1bFpdkgKckC1IpfXA_vrjSmL9ZtjmTju8ApwbT",
     "check_interval": 900,
     "key_of_credentials": "douyin_wentao_credentials",
-    "min_date2": "2025-10-02 00:00:00",
+    "min_date2": "2025-10-12 00:00:00",
     "output_video_dir": "data/tasks/chenjieshen_douyin_video_to_bilibili/video/douyin/陈杰森",
     "output_video_info_file": "data/tasks/chenjieshen_douyin_video_to_bilibili/video/douyin/陈杰森/file_info.json"
   },
@@ -17,7 +17,7 @@
     "sec_user_id": "MS4wLjABAAAA49QFP6YhorLIIX9M-FiZeKxmqhqXlttluSsZeaxvxzU",
     "check_interval": 900,
     "key_of_credentials": "douyin_wentao_credentials",
-    "min_date2": "2025-10-02 00:00:00",
+    "min_date2": "2025-10-12 00:00:00",
     "output_video_dir": "data/tasks/chenjieshen_douyin_video_to_bilibili/video/douyin/陈杰森",
     "output_video_info_file": "data/tasks/chenjieshen_douyin_video_to_bilibili/video/douyin/陈杰森/file_info.json"
   },
@@ -31,6 +31,6 @@
     "target_user_id": "442286660",
     "key_of_credentials": "bilibili_chenjiesen_credentials",
     "remove_after_upload": true,
-    "min_date2": "2025-10-02 00:00:00"
+    "min_date2": "2025-10-12 00:00:00"
   }
 ]

data/porter_tasks/porter_task_chenjieshen_douyin_video_to_youtube.json

@@ -6,7 +6,7 @@
     "sec_user_id": "MS4wLjABAAAATGoBrO7yiJ3q9go4fxq9JXjrnP1bFpdkgKckC1IpfXA_vrjSmL9ZtjmTju8ApwbT",
     "check_interval": 900,
     "key_of_credentials": "douyin_wentao_credentials",
-    "min_date2": "2025-10-02 00:00:00",
+    "min_date2": "2025-10-12 00:00:00",
     "output_video_dir": "data/tasks/chenjieshen_douyin_video_to_youtube/video/douyin/陈杰森",
     "output_video_info_file": "data/tasks/chenjieshen_douyin_video_to_youtube/video/douyin/陈杰森/file_info.json"
   },
@@ -17,7 +17,7 @@
     "sec_user_id": "MS4wLjABAAAA49QFP6YhorLIIX9M-FiZeKxmqhqXlttluSsZeaxvxzU",
     "check_interval": 900,
     "key_of_credentials": "douyin_wentao_credentials",
-    "min_date2": "2025-10-02 00:00:00",
+    "min_date2": "2025-10-12 00:00:00",
     "output_video_dir": "data/tasks/chenjieshen_douyin_video_to_youtube/video/douyin/陈杰森",
     "output_video_info_file": "data/tasks/chenjieshen_douyin_video_to_youtube/video/douyin/陈杰森/file_info.json"
   },
@@ -34,6 +34,6 @@
     "remove_after_upload_delay": 1,
     "playlist_title": "Short",
     "playlist_id": "PL1KtQ49rVMElugHudIdyKLAmgmMVdqoxQ",
-    "min_date2": "2025-10-02 00:00:00"
+    "min_date2": "2025-10-12 00:00:00"
   }
 ]

data/porter_tasks/porter_task_chenjing_douyin_live_record_to_youtube.json

@@ -4,6 +4,7 @@
     "type": "douyin_live_record",
     "room_name": "大成说创业",
     "room_id": "29576618707",
+    "sec_user_id": "MS4wLjABAAAAg0Oc_5SoYi4hrpc6xy-Yzuy1KrwV-zXw54JSqE4TW88",
     "key_of_credentials": "douyin_wentao_credentials",
     "check_interval": 10,
     "output_video_dir": "data/tasks/chenjing_douyin_live_record_to_youtube/live_record/",

data/porter_tasks/porter_task_lvxiaotong_douyin_live_record_to_youtube.json

@@ -4,6 +4,7 @@
     "type": "douyin_live_record",
     "room_name": "吕晓彤",
     "room_id": "25132757833",
+    "sec_user_id": "MS4wLjABAAAAqejZxZKopDBDEzxcQp-_1b019FfM05C0NzjQNpc5ylU",
     "key_of_credentials": "douyin_wentao_credentials",
     "check_interval": 10,
     "output_video_dir": "data/tasks/lvxiaotong_douyin_live_record_to_youtube/live_record/吕晓彤",

toolbox/douyin/homepage/follow.py

@@ -5,6 +5,9 @@ import asyncio
 import json
 import logging
 
+import httpx
+from tenacity import before_sleep_log, retry, retry_if_exception_type, stop_after_attempt, wait_fixed
+
 from project_settings import project_path
 from toolbox.douyin.douyin_client import DouyinClient
 from toolbox.asyncio.cacheout import async_cache_decorator
@@ -86,6 +89,89 @@ class FollowManager(DouyinClient):
 
         return result
 
+    async def check_user_live_status_by_user_id(self, user_id: str):
+        url = "https://live.douyin.com/webcast/distribution/check_user_live_status/"
+
+        params = {
+            # "user_ids": "1450989587539357",
+            "user_ids": user_id,
+            "aid": "6383",
+        }
+
+        async_session = httpx.AsyncClient(
+            http2=True,
+            limits=httpx.Limits(max_keepalive_connections=100, keepalive_expiry=100),
+            headers=self.headers,
+        )
+        response = await async_session.request("GET", url, params=params)
+        if response.status_code != 200:
+            raise AssertionError(f"request failed, status_code: {response.status_code}, text: {response.text}")
+
+        js = response.json()
+        return js
+
+    async def get_room_info_by_scene_by_room_id(self, room_id: str):
+        url = "https://live.douyin.com/webcast/room/info_by_scene/"
+
+        params = {
+            "aid": "6383",
+            "app_name": "douyin_web",
+            "live_id": "1",
+            "device_platform": "web",
+            "language": "zh-CN",
+            "enter_from": "web_homepage_hot",
+            "cookie_enabled": "true",
+            "browser_name": "Chrome",
+            "browser_version": "141.0.0.0",
+            "room_id": room_id,
+            # "room_id": "7560205524554320680",
+            "scene": "pc_profile_struct",
+
+        }
+
+        async_session = httpx.AsyncClient(
+            http2=True,
+            limits=httpx.Limits(max_keepalive_connections=100, keepalive_expiry=100),
+            headers=self.headers,
+        )
+        response = await async_session.request("GET", url, params=params)
+        if response.status_code != 200:
+            raise AssertionError(f"request failed, status_code: {response.status_code}, text: {response.text}")
+
+        js = response.json()
+        return js
+
+    @async_cache_decorator(1000000000)
+    @retry(
+        wait=wait_fixed(10),
+        stop=stop_after_attempt(3),
+        before_sleep=before_sleep_log(logger, logging.ERROR),
+    )
+    async def get_user_info_by_sec_user_id(self, sec_user_id: str):
+        url = "https://www.douyin.com/aweme/v1/web/user/profile/other/"
+
+        params = {
+            "device_platform": "webapp",
+            "aid": "6383",
+            "channel": "channel_pc_web",
+            "sec_user_id": sec_user_id,
+        }
+
+        # 需要登录cookies
+        response = await self.async_session.request(
+            "GET", url,
+            headers={
+                **self.headers,
+                "referer": "https://www.douyin.com/user"
+            },
+            params=params,
+        )
+        if response.status_code != 200:
+            raise AssertionError(f"request failed, status_code: {response.status_code}, text: {response.text}")
+
+        js = response.json()
+        return js
+
 
 def get_args():
     parser = argparse.ArgumentParser()
@@ -115,7 +201,13 @@ async def main():
     flag = client.check_login()
     print(f"flag: {flag}")
 
-    js = await client.get_living_list()
+    # js = await client.get_living_list()
+
+    # js = await client.get_room_info_by_scene()
+
+    js = await client.get_user_info_by_sec_user_id(
+        sec_user_id="MS4wLjABAAAAf0qOK8d42d4y5nAFzm-MOI31El_mtLMIR6M-TmewcZDtJOM54w9gx9cmIDDpByFJ"
+    )
     print(f"js: {json.dumps(js, ensure_ascii=False, indent=4)}")
     return
 

toolbox/douyin/live/live_recording.py

@@ -177,6 +177,57 @@ class LiveRecording(FollowManager):
                 break
         return result
 
+    async def get_live_info_by_sec_user_id(self, sec_user_id: str):
+        js = await self.get_user_info_by_sec_user_id(sec_user_id)
+        status_code = js["status_code"]
+        if status_code != 0:
+            raise AssertionError(f"request failed; status_code {status_code}, msg: {js['status_msg']}")
+
+        user_info = js["user"]
+        uid = user_info["uid"]
+
+        result = await self.get_live_info_by_user_id(user_id=str(uid))
+        return result
+
+    @async_cache_decorator(10)
+    @retry(
+        wait=wait_fixed(10),
+        stop=stop_after_attempt(3),
+        before_sleep=before_sleep_log(logger, logging.ERROR),
+    )
+    async def get_live_info_by_user_id(self, user_id: str):
+        js = await self.check_user_live_status_by_user_id(user_id=str(user_id))
+        user_live = js["data"][0]["user_live"]
+        if len(user_live) == 0:
+            result = {
+                "status": 4,  # 未开播
+                "title": "",
+                "stream_data": dict(),
+                "paid_live_data": dict(),
+            }
+            return result
+
+        data = user_live[0]
+        room_id = data["room_id"]
+
+        js = await self.get_room_info_by_scene_by_room_id(room_id)
+        data = js["data"]
+        status = data["status"]
+        title = data["title"]
+        stream_data = json.loads(data["stream_url"]["live_core_sdk_data"]["pull_data"]["stream_data"])
+        stream_data = stream_data["data"]
+
+        paid_live_data = data["paid_live_data"]
+
+        result = {
+            "status": status,
+            "title": title,
+            "stream_data": stream_data,
+
+            "paid_live_data": paid_live_data,
+        }
+        return result
+
     @async_cache_decorator(600)
     @retry(
         wait=wait_fixed(60),
@@ -226,9 +277,16 @@ async def main():
     print(f"flag: {flag}")
 
     # js = await client.get_live_info_by_web_enter(room_id="770758107267")
-    js = await client.get_live_info_by_room_url(room_id="680837692624")
+    # js = await client.get_live_info_by_room_url(room_id="680837692624")
     # js = await client.get_live_info_by_follow(room_id="876191604909")
     # js = await client.get_live_info_by_follow(room_id="572033528289")
+
+    js = await client.get_live_info_by_sec_user_id(
+        # sec_user_id="MS4wLjABAAAA_vx5smDIz-u2d5o0vL3UPNVuznz_8Z9ZwGa0ULzj4rZfU5CsNoBhR_ltGF7pz7yi",
+        # sec_user_id="MS4wLjABAAAAgd9H8yTMv9zn8AlgK5YXtqMi7PZMU2plnW7N1ZFA12_jsAuZL_NrBOUCwCYixRLx",
+        sec_user_id="MS4wLjABAAAAf0qOK8d42d4y5nAFzm-MOI31El_mtLMIR6M-TmewcZDtJOM54w9gx9cmIDDpByFJ",
+    )
+    # js = await client.get_live_info_by_user_id(user_id="1450989587539357")
     print(f"js: {json.dumps(js, ensure_ascii=False, indent=4)}")
     return
 

toolbox/douyin/video/download.py

@@ -8,7 +8,6 @@ import logging
 from pathlib import Path
 from zoneinfo import ZoneInfo
 
-from gradio.cli.commands.deploy_space import readme_file
 from tenacity import before_sleep_log, retry, retry_if_exception_type, stop_after_attempt, wait_fixed
 
 from project_settings import project_path, time_zone_info

toolbox/porter/tasks/douyin_live_record_task.py

@@ -34,6 +34,7 @@ class DouyinLiveRecordTask(BaseTask):
     def __init__(self,
                  room_name: str,
                  room_id: str,
+                 sec_user_id: str,
                  key_of_credentials: str,
                  check_interval: int,
                  output_video_dir: str = "output",
@@ -45,6 +46,7 @@ class DouyinLiveRecordTask(BaseTask):
         )
         self.room_name = room_name
         self.room_id = room_id
+        self.sec_user_id = sec_user_id
         self.key_of_credentials = key_of_credentials
 
         if not os.path.isabs(output_video_dir):
@@ -73,9 +75,11 @@ class DouyinLiveRecordTask(BaseTask):
         max_length = 50
         self.success_rate_of_get_live_info_by_web_enter = collections.deque(maxlen=max_length)
         self.success_rate_of_get_live_info_by_room_url = collections.deque(maxlen=max_length)
+        self.success_rate_of_get_live_info_by_sec_user_id = collections.deque(maxlen=max_length)
         self.success_rate_of_get_live_info_by_follow = collections.deque(maxlen=max_length)
         self.success_rate_of_get_live_info_by_web_enter.extend([1] * max_length)
         self.success_rate_of_get_live_info_by_room_url.extend([1] * max_length)
+        self.success_rate_of_get_live_info_by_sec_user_id.extend([1] * max_length)
         self.success_rate_of_get_live_info_by_follow.extend([1] * max_length)
 
     def get_video_info(self, title):
@@ -174,6 +178,22 @@ class DouyinLiveRecordTask(BaseTask):
             self.success_rate_of_get_live_info_by_room_url.append(1)
         return result
 
+    async def get_live_info_by_sec_user_id(self):
+        success_rate = np.mean([flag for flag in self.success_rate_of_get_live_info_by_sec_user_id])
+        logger.debug(f"{self.flag} success_rate_of_get_live_info_by_sec_user_id success_rate: {success_rate}")
+        if random.random() > max(float(success_rate), 0.03):
+            return None
+        try:
+            result = await self.douyin_client.get_live_info_by_sec_user_id(self.sec_user_id)
+        except Exception as error:
+            logger.error(f"get_live_info_by_sec_user_id failed; error type: {type(error)}, error text: {error}, traceback: {traceback.format_exc()}")
+            result = None
+        if result is None:
+            self.success_rate_of_get_live_info_by_sec_user_id.append(0)
+        else:
+            self.success_rate_of_get_live_info_by_sec_user_id.append(1)
+        return result
+
     async def get_live_info_by_follow(self):
         success_rate = np.mean([flag for flag in self.success_rate_of_get_live_info_by_follow])
         logger.debug(f"{self.flag} get_live_info_by_follow success_rate: {success_rate}")
@@ -210,6 +230,9 @@ class DouyinLiveRecordTask(BaseTask):
         if js is None:
             live_check_method = "by_room_url"
             js = await self.get_live_info_by_room_url()
+        if js is None:
+            live_check_method = "by_sec_user_id"
+            js = await self.get_live_info_by_sec_user_id()
         if js is None:
             live_check_method = "by_follow"
             js = await self.get_live_info_by_follow()

toolbox/porter/tasks/douyin_live_to_bilibili_live_task.py

@@ -29,6 +29,7 @@ class DouyinLiveToBilibiliLiveTask(BaseTask):
     def __init__(self,
                  room_name: str,
                  room_id: str,
+                 sec_user_id: str,
                  check_interval: int,
                  key_of_douyin_credentials: str,
                  key_of_bilibili_credentials: str,
@@ -39,6 +40,7 @@ class DouyinLiveToBilibiliLiveTask(BaseTask):
         )
         self.room_name = room_name
         self.room_id = room_id
+        self.sec_user_id = sec_user_id
         self.key_of_douyin_credentials = key_of_douyin_credentials
         self.key_of_bilibili_credentials = key_of_bilibili_credentials
 
@@ -59,9 +61,11 @@ class DouyinLiveToBilibiliLiveTask(BaseTask):
         max_length = 50
         self.success_rate_of_get_live_info_by_web_enter = collections.deque(maxlen=max_length)
         self.success_rate_of_get_live_info_by_room_url = collections.deque(maxlen=max_length)
+        self.success_rate_of_get_live_info_by_sec_user_id = collections.deque(maxlen=max_length)
         self.success_rate_of_get_live_info_by_follow = collections.deque(maxlen=max_length)
         self.success_rate_of_get_live_info_by_web_enter.extend([1] * max_length)
         self.success_rate_of_get_live_info_by_room_url.extend([1] * max_length)
+        self.success_rate_of_get_live_info_by_sec_user_id.extend([1] * max_length)
         self.success_rate_of_get_live_info_by_follow.extend([1] * max_length)
 
         # state
@@ -108,6 +112,18 @@ class DouyinLiveToBilibiliLiveTask(BaseTask):
             self.success_rate_of_get_live_info_by_room_url.append(1)
         return result
 
+    async def get_live_info_by_sec_user_id(self):
+        success_rate = np.mean([flag for flag in self.success_rate_of_get_live_info_by_sec_user_id])
+        logger.debug(f"{self.flag} success_rate_of_get_live_info_by_sec_user_id success_rate: {success_rate}")
+        if random.random() > max(float(success_rate), 0.03):
+            return None
+        result = await self.douyin_client.get_live_info_by_sec_user_id(self.sec_user_id)
+        if result is None:
+            self.success_rate_of_get_live_info_by_sec_user_id.append(0)
+        else:
+            self.success_rate_of_get_live_info_by_sec_user_id.append(1)
+        return result
+
     async def get_live_info_by_follow(self):
         success_rate = np.mean([flag for flag in self.success_rate_of_get_live_info_by_follow])
         logger.debug(f"{self.flag} get_live_info_by_follow success_rate: {success_rate}")
@@ -145,6 +161,9 @@ class DouyinLiveToBilibiliLiveTask(BaseTask):
         if js is None:
             live_check_method = "by_room_url"
             js = await self.get_live_info_by_room_url()
+        if js is None:
+            live_check_method = "by_sec_user_id"
+            js = await self.get_live_info_by_sec_user_id()
         if js is None:
             live_check_method = "by_follow"
             js = await self.get_live_info_by_follow()