Update app.py

app.py

@@ -7,7 +7,8 @@ import time
 import re
 import json
 import base64
-
+import asyncio
+import aiohttp
 from unidecode import unidecode
 
 api_key_sys = os.getenv('api_key_sys')  
@@ -109,13 +110,59 @@ 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 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)
+
+            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)
 
+                # Формирование URL для второго запроса по export_id
+                export_url_template = f"{gc_url_export}/{export_id}?key={gc_api}"
+
+                # Отправка второго запроса к серверу по export_id
+                export_data = await fetch(session, export_url_template)
+
+                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"))
+    else:
+        print("Системная переменная start_up не равна '1' или код уже выполнялся при старте сервера.")