Update app.py

app.py

@@ -28,6 +28,15 @@ basicConfig(
     filemode='a'
 )
 logger = getLogger('proxy_collector')
+logger.info('запуск...')
+
+
+def delete_logs():
+    try:
+        logfile.unlink()
+    except Exception as e:
+        logger.error(f'ошибка при удалении логов: {e}')
+
 
 is_first_run = True
 
@@ -40,6 +49,7 @@ countries_list = ['US', 'CA', 'FR', 'FI', 'HR', 'ME', 'CH', 'SE', 'EE', 'DE', 'G
 
 
 def create_json_from_proxies(proxy_lines: list[str], filename: Path):
+    logger.info('сохранение файла прокси')
     countries = set()
     proxies = []
 
@@ -72,11 +82,12 @@ async def collect_proxies(proxies_queue: Queue):
         if proxy is None:
             break
         proxies_list.append(f'{proxy}')
-        print(f"\rtotal proxies: {len(proxies_list)}", end='')
+        # print(f"\rtotal proxies: {len(proxies_list)}", end='')
     return proxies_list
 
 
 async def sort_proxies_and_merge(files: list[Path], output_file: Path):
+    logger.info('объединение файлов прокси')
     all_countries = set()
     proxies_by_type = {}
     for file in files:
@@ -116,7 +127,7 @@ async def find_proxies_by_type(proxy_type: Literal['HTTP', 'HTTPS', 'SOCKS5'], o
     await broker.find(types=[proxy_type], countries=countries_list, limit=0)
     await stop_task
     proxies_list = await collect_proxies(proxies_queue)
-    saved_proxy =  create_json_from_proxies(proxies_list, output_json_file)
+    saved_proxy = create_json_from_proxies(proxies_list, output_json_file)
     logger.info(f'завершён сбор прокси {proxy_type}')
     return saved_proxy
 
@@ -136,6 +147,7 @@ async def find_proxies():
 
 
 scheduler.add_job(find_proxies, 'interval', max_instances=1, minutes=60)
+scheduler.add_job(delete_logs, 'interval', max_instances=1, minutes=1440)
 
 
 @asynccontextmanager