49 lines
1.3 KiB
Python
49 lines
1.3 KiB
Python
from apscheduler.schedulers.blocking import BlockingScheduler
|
|
import modules.read_config
|
|
import modules.fileRW
|
|
import modules.device
|
|
import monitor
|
|
import logging
|
|
|
|
|
|
|
|
def main():
|
|
cache_file_path = modules.read_config.read_config_ini()
|
|
logging.info(f"读取到的配置文件路径：{cache_file_path}")
|
|
modules.fileRW.delete_file(cache_file_path)
|
|
devices = modules.device.get_adb_devices()
|
|
if devices != []:
|
|
for device in devices:
|
|
logging.info(f"检查{device}Proxy是否存活")
|
|
device_status = monitor.monitor(device)
|
|
logging.info(f"{device} status {device_status}")
|
|
if device_status == False:
|
|
print(f"异常设备，{device}")
|
|
logging.error(f"异常设备，{device}")
|
|
modules.fileRW.write_error_devices(device)
|
|
else:
|
|
logging.error(f"main error: devices=[]")
|
|
|
|
|
|
|
|
|
|
|
|
if __name__ == '__main__':
|
|
# 初始化日志配置
|
|
logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(message)s')
|
|
|
|
# 创建调度器
|
|
scheduler = BlockingScheduler()
|
|
|
|
# 添加定时任务，每二十分钟执行一次 main() 函数
|
|
scheduler.add_job(main, 'interval', minutes=20)
|
|
|
|
# 开始调度器
|
|
try:
|
|
scheduler.start()
|
|
except KeyboardInterrupt:
|
|
pass
|
|
|
|
#
|
|
# if __name__ == '__main__':
|
|
# main() |