107 lines
3.4 KiB
Python
107 lines
3.4 KiB
Python
#!/usr/bin/env python3
|
||
# -*- coding: utf-8 -*-
|
||
"""
|
||
定时执行 init_proxy.py 脚本
|
||
每整十分钟执行一次（00、10、20、30、40、50分）
|
||
"""
|
||
|
||
import time
|
||
import datetime
|
||
import subprocess
|
||
import sys
|
||
import os
|
||
import logging
|
||
from pathlib import Path
|
||
|
||
# 设置日志
|
||
logging.basicConfig(
|
||
level=logging.INFO,
|
||
format='%(asctime)s - %(levelname)s - %(message)s',
|
||
handlers=[
|
||
logging.FileHandler('scheduler_init_proxy.log', encoding='utf-8'),
|
||
logging.StreamHandler()
|
||
]
|
||
)
|
||
logger = logging.getLogger(__name__)
|
||
|
||
def execute_init_proxy():
|
||
"""执行 init_proxy.py 脚本"""
|
||
try:
|
||
script_path = Path(__file__).parent / "init_proxy.py"
|
||
if not script_path.exists():
|
||
logger.error(f"脚本文件不存在: {script_path}")
|
||
return False
|
||
|
||
# 使用当前 Python 解释器执行脚本 - 兼容老版本Python
|
||
result = subprocess.run(
|
||
[sys.executable, str(script_path)],
|
||
stdout=subprocess.PIPE,
|
||
stderr=subprocess.PIPE,
|
||
universal_newlines=True
|
||
)
|
||
|
||
if result.returncode == 0:
|
||
logger.info("init_proxy.py 执行成功")
|
||
if result.stdout and result.stdout.strip():
|
||
logger.info(f"输出: {result.stdout.strip()}")
|
||
else:
|
||
logger.error(f"init_proxy.py 执行失败，返回码: {result.returncode}")
|
||
if result.stderr and result.stderr.strip():
|
||
logger.error(f"错误信息: {result.stderr.strip()}")
|
||
|
||
return result.returncode == 0
|
||
|
||
except Exception as e:
|
||
logger.error(f"执行 init_proxy.py 时发生异常: {e}")
|
||
return False
|
||
|
||
def wait_for_next_execution():
|
||
"""等待到下一个整十分钟"""
|
||
now = datetime.datetime.now()
|
||
current_minute = now.minute
|
||
|
||
# 计算下一个整十分钟
|
||
next_minute = ((current_minute // 10) + 1) * 10
|
||
|
||
# 处理小时进位
|
||
if next_minute >= 60:
|
||
next_minute = 0
|
||
next_execution = now.replace(minute=0, second=0, microsecond=0) + datetime.timedelta(hours=1)
|
||
else:
|
||
next_execution = now.replace(minute=next_minute, second=0, microsecond=0)
|
||
|
||
wait_seconds = (next_execution - now).total_seconds()
|
||
logger.info(f"当前时间: {now.strftime('%Y-%m-%d %H:%M:%S')}")
|
||
logger.info(f"下次执行时间: {next_execution.strftime('%Y-%m-%d %H:%M:%S')}")
|
||
logger.info(f"等待 {wait_seconds:.0f} 秒")
|
||
|
||
return wait_seconds
|
||
|
||
def main():
|
||
"""主函数"""
|
||
logger.info("代理重置定时器启动")
|
||
logger.info("脚本将在每整十分钟执行一次 init_proxy.py")
|
||
|
||
# 首次执行
|
||
logger.info("执行首次代理重置...")
|
||
execute_init_proxy()
|
||
|
||
# 定时循环
|
||
while True:
|
||
try:
|
||
wait_seconds = wait_for_next_execution()
|
||
time.sleep(wait_seconds)
|
||
|
||
logger.info("开始执行定时任务...")
|
||
execute_init_proxy()
|
||
|
||
except KeyboardInterrupt:
|
||
logger.info("接收到中断信号，程序退出")
|
||
break
|
||
except Exception as e:
|
||
logger.error(f"定时器运行异常: {e}")
|
||
# 发生异常时等待60秒后继续
|
||
time.sleep(60)
|
||
|
||
if __name__ == "__main__":
|
||
main() |