diff --git a/config/URL_config.ini b/config/URL_config.ini index d433cb5..1c5a768 100644 --- a/config/URL_config.ini +++ b/config/URL_config.ini @@ -1,4 +1,5 @@ https://live.douyin.com/456576000931,主播: 介休〖烩饕〗大块牛肉饭「摆摊」 +https://live.douyin.com/270513395244,主播: 小喻的摆摊日记 https://live.douyin.com/742474761291,主播: 阿诺椰子• https://live.douyin.com/820845121901,主播: 地摊闺蜜_创意寿司_(马儿努力版) https://live.douyin.com/980855021360,主播: 图爸摆摊卖枣糕(日照首家)教学员 diff --git a/main.py b/main.py index 5f10263..caec550 100644 --- a/main.py +++ b/main.py @@ -41,6 +41,7 @@ from ffmpeg_install import ( + version = "v4.0.7" platforms = ("\n国内站点:抖音|快手|虎牙|斗鱼|YY|B站|小红书|bigo|blued|网易CC|千度热播|猫耳FM|Look|TwitCasting|百度|微博|" "酷狗|花椒|流星|Acfun|畅聊|映客|音播|知乎|嗨秀|VV星球|17Live|浪Live|漂漂|六间房|乐嗨|花猫|淘宝|京东|咪咕|连接|来秀" @@ -1164,6 +1165,9 @@ def start_record(url_data: tuple, count_variable: int = -1) -> None: if port_info['is_live'] is False: print(f"\r{record_name} 等待直播... ") + # 直接退出线程eric + return + if start_pushed: if over_show_push: push_content = "直播间状态更新:[直播间名称] 直播已结束!时间:[时间]" @@ -1182,6 +1186,10 @@ def start_record(url_data: tuple, count_variable: int = -1) -> None: else: content = f"\r{record_name} 正在直播中..." print(content) + # 检查是否已有直播在录制 + if len(recording) > 0 : + # 如果已有直播在录制,跳过这次录制(主播在线) + return # 或者 continue,如果在循环中 if live_status_push and not start_pushed: if begin_show_push: @@ -1290,10 +1298,7 @@ def start_record(url_data: tuple, count_variable: int = -1) -> None: if proxy_address: ffmpeg_command.insert(1, "-http_proxy") ffmpeg_command.insert(2, proxy_address) - # 检查是否已有直播在录制 - if len(recording) > 0: - # 如果已有直播在录制,跳过这次录制 - return # 或者 continue,如果在循环中 + recording.add(record_name) start_record_time = datetime.datetime.now() recording_time_list[record_name] = [start_record_time, record_quality_zh] @@ -1616,7 +1621,7 @@ def start_record(url_data: tuple, count_variable: int = -1) -> None: else: - # ====================== 抖音→YouTube 2025(重构:单层重试 + 统一清理) ====================== + # ====================== 抖音→YouTube 2025(重构:单层重试 + 统一清理) ====================== import queue, unicodedata, platform, traceback class StreamEnded(Exception): @@ -2427,9 +2432,15 @@ while True: create_var[f'thread_{monitoring}'].start() running_list.append(url_tuple[1]) time.sleep(local_delay_default) + + + + url_tuples_list = [] first_start = False + + except Exception as err: logger.error(f"错误信息: {err} 发生错误的行数: {err.__traceback__.tb_lineno}")