Видеоинструкция по установке

Посмотрите пошаговый процесс установки и настройки Alpha.Domain.Client.

• Откройте Alpha DevStudio

• Создайте новый проект или откройте существующий

• Добавьте необходимые объекты и сигналы в проект

• Включите архивирование для нужных сигналов

• Сохраните проект

• Выполните проливку конфигурации на Alpha.Server

• Убедитесь в успешной проливке и запуске конфигурации

requested_items = runtime_node.get_items(item_names)
items = []
for item in requested_items:
    item.init()
    if item.status_info.item_status == ng.ItemStatus.INITIALIZED:
        items.append(item)

Ключевые моменты:

• get_items(names): получает объекты Item по именам.

• item.init(): инициализирует элемент - обязательный шаг.

• ItemStatus.INITIALIZED: статус готовности элемента.

for item in items:
    try:
        vqt = item.get_value()
        print(f"- {item.name}: {vqt.value}")
        data_logger.write_data(item.name, vqt.value, vqt.quality)
    except Exception as e:
        print(f"X Ошибка: {e}")

service = ng.create_tag_service()
unit = service.create_unit()
endpoint = ng.TcpEndpoint(host, port)
        
settings = ng.ServerSettings(3000, endpoint)
test_node = unit.create_node_connection(settings, Logger())
        
test_node.connect()
if test_node.is_connected():
    print("Подключение ... успешно!")
    test_node.disconnect()
    return True
else:
    return False

Ключевые моменты:

• ng.TcpEndpoint(host, port): определяет адрес сервера.

• ng.ServerSettings(...): настройки для подключения к Alpha.Server (оперативные данные).

• unit.create_node_connection(...): создает узел подключения.

def create_alpha_datetime_with_timezone(dt):
    try:
        if dt.tzinfo is None:
            msk_timezone = timezone(timedelta(hours=3))
            dt_with_tz = dt.replace(tzinfo=msk_timezone)
        else:
            dt_with_tz = dt
        
        utc_dt = dt_with_tz.astimezone(timezone.utc)
        
        return ng.DateTime(utc_dt.replace(tzinfo=None))
    except Exception as e:
        print(f"Ошибка создания Alpha DateTime: {e}")
        return ng.DateTime(dt)

Ключевые моменты:

• ng.DateTime: конструктор SDK для времени.

• .astimezone(timezone.utc): стандартный метод Python для конвертации в UTC.

• При чтении данных (см. след. блок) выполняется обратная операция: convert_alpha_time_to_local().

value_reader = history_node.create_value_read_session()
        
low_bound = ng.HistoryBound(create_alpha_datetime_with_timezone(start_dt), ng.HistoryBoundType.OUTER)
high_bound = ng.HistoryBound(create_alpha_datetime_with_timezone(end_dt), ng.HistoryBoundType.OUTER)

history_pipe = value_reader.read(low_bound, high_bound, True, 10000, item)

count = 0

while not history_pipe.is_over():
    status, vqt = history_pipe.fetch_next(5000)
    
    if status == ng.PipeFetchStatus.SUCCESS and vqt:
        local_time = convert_alpha_time_to_local(vqt.timestamp)
        
        logger.write_data(
            f"HISTORY_{item.name}", 
            vqt.value, 
            vqt.quality, 
            "HISTORY_READ", 
            "SUCCESS",
            local_time.strftime('%Y-%m-%d %H:%M:%S')
        )
        count += 1
        
    elif status == ng.PipeFetchStatus.DATA_IS_OVER:
        print("Чтение истории завершено - достигнут конец данных")
        break
    elif status == ng.PipeFetchStatus.TIMEOUT_EXCEEDED:
        print("Превышен timeout ожидания данных")
        break

Ключевые моменты:

• create_value_read_session(): cоздает сессию для чтения истории.

• value_reader.read(...): возвращает `DataPipe` (канал данных).

• history_pipe.fetch_next(): получает следующий элемент VQT (Value, Quality, Timestamp) из канала.

• PipeFetchStatus: необходимо проверять статус, чтобы понять, закончились ли данные (`DATA_IS_OVER`) или произошла ошибка.

Демонстрация работы скрипта

Пример подключения к альфа серверу и выгрузки данных в .csv.