/
kotkov
/
eco
Обзор
Документация
Войти
/
kotkov
/
eco
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
dev
tests/test_proxy.py
46 строк
2 KB
Arseny Kotkov
Add multithreading logging to file with log.ecolog
04 мар 2025, 08:01
04 мар 2025, 08:01
03de008
Код
Авторство
О чём код?
from threading import Thread from aaa import AAA from log import ecolog from rpc import Message from scheduler import Scheduler from slurm import Slurm from utils import Socket def test_proxy(): try: # Создаём экземпляр центра регистрации агентов. aaa = AAA() aaa_socket = Socket('127.0.0.1', 5000) # Запускаем RPC-сервер центра регистрации агентов. t0 = Thread(target=aaa.serve, args=(('127.0.0.1', 5000),)) t0.daemon = True t0.start() # Создаём экземпляр агента доступа к вычислительным ресурсам. slurm = Slurm() slurm.name = "slurm" slurm.aaa = aaa_socket # Запускаем RPC-сервер агента доступа к вычислительным ресурсам. t1 = Thread(target=slurm.serve, args=(('127.0.0.1', 50010),)) t1.daemon = True t1.start() ecolog() # Пустая строка для повышения удобочитаемости вывода. # Регистрируем агентов в центре регистрации. ecolog(slurm.register()) # Создаём прокси для Slurm from proxy_agent import ProxyAgent slurm_proxy = ProxyAgent('127.0.0.1', 50010, "MySlurm", aaa) # Как использовать прокси # ... except KeyboardInterrupt: exit(0)