engine = create_engine('sqlite:///db.sqlite3', connect_args={'check_same_thread': False})import threading
import queue
from sqlalchemy import create_engine
# Создаем очередь запросов
query_queue = queue.Queue()
# Функция для выполнения запросов
def execute_queries():
# Создаем движок SQLAlchemy
engine = create_engine('sqlite:///db.sqlite3', connect_args={'check_same_thread': False})
while True:
# Получаем запрос из очереди
query = query_queue.get()
if query is None:
break
# Выполняем запрос
with engine.connect() as connection:
connection.execute(query)
# Сообщаем, что запрос выполнен
query_queue.task_done()
# Запускаем поток для выполнения запросов
query_thread = threading.Thread(target=execute_queries)
query_thread.start()
# Помещаем запросы в очередь
query_queue.put("INSERT INTO table_name (column1, column2) VALUES (value1, value2)")
query_queue.put("SELECT * FROM table_name WHERE condition")
# Ждем завершения всех запросов
query_queue.join()
# Завершаем поток после выполнения всех запросов
query_queue.put(None)
query_thread.join()Если правильно понял, вы создаете для каждого объявления дубликат кампании (можно и группы, вроде разницы не будет)?
И как же за этим потом следить и управлять?)
Вот у меня сейчас под 10 проработанных баннеров (спец предложений) и все под 1 таргетинг
ужасная ведь структура получается...
asyncio использует все доступные ядра и сама распределяет всё между ними?