Зачастую при работе с Альфа платформой приходится обрабатывать большие объёмы оперативных и исторических данных.

Традиционный синхронный подход при этом приостанавливает выполнение процесса до завершения операции, что неприемлемо.

Alpha.Domain.Client решает эту проблему с помощью механизма AsyncOperation, который позволяет выполнять длительные операции асинхронно, не блокируя процесс.

• Блокирует поток

• Возвращает Value (Vqt)

• Не блокирует поток

• Возвращает Operation

RUNTIME

• Чтение текущих значений (Snapshot)

• Подписки на изменения в реальном времени

• Требует низкой задержки (<100 мс)

HISTORIAN

• Выгрузка архивных данных

• Сложные SQL-запросы к истории

• Может занимать секунды или минуты

async def read_data(pool_manager):
    # Захват соединения из нужной зоны
    connection = await pool_manager.get_connection(PoolZone.RUNTIME)
    try:
        items = connection.node.get_items(["Tag1"])
        return items
    finally:
        # Гарантированный возврат соединения обратно в пул
        await pool_manager.release_connection(connection)

# Запрос потока данных (Pipe)
pipe = reader.read(low_bound, high_bound, True, 10000, item)
while not pipe.is_over():
    # 5000 - таймаут ожидания (мс)
    status, vqt = pipe.fetch_next(5000)
    
    if status == ng.PipeFetchStatus.SUCCESS:
        process(vqt) # Обработка пачки данных
    elif status == ng.PipeFetchStatus.DATA_IS_OVER:
        break
        
pipe.close()

Event Loop & Task Queue

Connection Pools