Update app.py

app.py

@@ -8,7 +8,7 @@ import re
 import json
 import base64
 import asyncio
-import aiohttp
+import httpx
 from unidecode import unidecode
 
 api_key_sys = os.getenv('api_key_sys')  
@@ -108,62 +108,69 @@ for db in DATABASES:
 
 
 
-
-
+# Флаг выполнения кода
 code_executed = False
 
 # Переменная для хранения данных
 export_data_var = None
 
-async def fetch(session, url):
-    async with session.get(url) as response:
-        return await response.json()
+async def fetch(url):
+    async with httpx.AsyncClient() as client:
+        response = await client.get(url)
+        return response.json()
+
+async def get_export_id():
+    url_template = f"{gc_url_gru}/{id_gru}/users?key={gc_api}&created_at[from]={date_from}&status={status}"
+    data = await fetch(url_template)
+    if data.get("success"):
+        return data.get("info", {}).get("export_id", "")
+    else:
+        raise Exception(f"Ошибка в ответе от сервера: {data.get('error_message')}")
+
+async def get_export_data(export_id):
+    export_url_template = f"{gc_url_export}/{export_id}?key={gc_api}"
+    data = await fetch(export_url_template)
+    if data.get("success"):
+        return data
+    else:
+        raise Exception(f"Ошибка при выполнении второго запроса по export_id, статус код: {data.get('status_code')}")
 
 async def main():
     global code_executed, export_data_var
 
     if start_up == '1' and not code_executed:
-        # Формирование URL для первого запроса
-        url_template = f"{gc_url_gru}/{id_gru}/users?key={gc_api}&created_at[from]={date_from}&status={status}"
-
-        async with aiohttp.ClientSession() as session:
-            # Отправка первого запроса к серверу
-            data = await fetch(session, url_template)
+        try:
+            export_id = await get_export_id()
+            print("Export ID:", export_id)
 
-            if data.get("success"):
-                export_id = data.get("info", {}).get("export_id", "")
-                print("Export ID:", export_id)
+            # Задержка в 5 минут перед вторым запросом (в секундах)
+            time_delay = 5 * 60
+            print(f"Ждем {time_delay} секунд перед вторым запросом...")
+            await asyncio.sleep(time_delay)
 
-                # Задержка в 5 минут перед вторым запросом (в секундах)
-                time_delay = 5 * 60
-                print(f"Ждем {time_delay} секунд перед вторым запросом...")
-                await asyncio.sleep(time_delay)
+            export_data = await get_export_data(export_id)
+            print("Полученные данные по export_id:", export_data)
 
-                # Формирование URL для второго запроса по export_id
-                export_url_template = f"{gc_url_export}/{export_id}?key={gc_api}"
+            # Сохранение данных в переменную
+            export_data_var = export_data
 
-                # Отправка второго запроса к серверу по export_id
-                export_data = await fetch(session, export_url_template)
+            # Пример использования переменной export_data_var
+            # Здесь вы можете выполнять любые операции с данными
+            print("Пример использования переменной export_data_var:")
+            print(export_data_var)
 
-                if export_data.get("success"):
-                    print("Полученные данные по export_id:", export_data)
-
-                    # Сохранение данных в переменную
-                    export_data_var = export_data
-
-                    # Пример использования переменной export_data_var
-                    # Здесь вы можете выполнять любые операции с данными
-                    print("Пример использования переменной export_data_var:")
-                    print(export_data_var)
-
-                    code_executed = True  # Устанавливаем флаг выполнения кода
-                else:
-                    print(f"Ошибка при выполнении второго запроса по export_id, статус код: {export_data.get('status_code')}")
-            else:
-                print("Ошибка в ответе от сервера:", data.get("error_message"))
+            code_executed = True  # Устанавливаем флаг выполнения кода
+        except Exception as e:
+            print(f"Ошибка: {e}")
     else:
         print("Системная переменная start_up не равна '1' или код уже выполнялся пр�� старте сервера.")
 
+app = Flask(__name__)
+
+@app.before_first_request
+def init_async():
+    asyncio.run(main())
+