Доступ к подпроцессу, запущенному другим скриптом ⇐ Python

[Anonymous]

У меня есть сценарий 1 (точка входа в контейнер). Сценарий 1 запускает подпроцесс с помощью Popen. Он «ждет» этого процесса, чтобы получить живые команды ввода с консоли и поддерживать работу сервера.

game_server = await asyncio.create_subprocess_exec(*run_command, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.PIPE, stdin=asyncio.subprocess.PIPE) асинхронность для start_out_line в game_server.stdout: console_print(startup_out_line.decode()) если server_start_string в start_out_line.decode('utf-8', 'replace'): print("Сервер запущен") перерыв асинхронно с asyncio.TaskGroup() как tg: in_task = tg.create_task(running_server_inpipe(game_server)) out_task = tg.create_task(running_server_outpipe(game_server)) err_task = tg.create_task(running_server_errpipe(game_server)) реткод = ожидание game_server.wait() если реткод == 0: print("Сервер завершился нормально") еще: print(f"Ошибка: сервер закрыт с кодом {retcode}") in_task.cancel() out_task.cancel() err_task.cancel() sys.exit(0, если реткод == 0, иначе 1) async def Running_server_inpipe(game_server: asyncio.subprocess.Process): пока правда: строка = ожидание aioconsole.ainput("Введите команду:") game_server.stdin.write(line.encode('utf-8') + b"\n") ожидайте game_server.stdin.drain() console_print("INPIPE — команда отправлена: " + строка) async def Running_server_outpipe(game_server: asyncio.subprocess.Process): асинхронность для out_line в game_server.stdout: console_print("OUTPIPE — Сервер говорит: " + out_line.decode('utf-8', 'replace')) async def Running_server_errpipe(game_server: asyncio.subprocess.Process): асинхронность для err_line в game_server.stderr: console_print("ERRORPIPE — Ошибка сервера: " + err_line.decode('utf-8', 'replace')) Тогда у меня есть сценарий 2 (API), который получает команды из внешнего источника и пытается получить доступ к подпроцессу, запущенному сценарием 1, и записать команду в его стандартный ввод.

@API1.route('/quit', методы=['POST']) защита получения_quit_data(): данные = request.get_json() пытаться: сервер = данные['сервер'] кроме KeyError: return jsonify({'status': 'Сервер не указан'}) Engage_container = ["docker", "attach", f"{server}"] Container_process = subprocess.Popen(engage_container, stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL, text=True) Container_process.communicate(input="quit\n") контейнер_процесс.ожидание() если контейнер_процесс.возвратный_код == 0: return jsonify({'status': 'Команда отправлена'}) return jsonify({'status': 'Command Failed'}) Хотя я получаю обратно код 200 от API. Подпроцесс вообще не отвечает на эти команды. Если я войду в терминал напрямую и напишу:

docker Attach тогда

сохранить\n он ​​реагирует так, как и ожидалось, и я знаю, что сценарий 1 работает правильно! Я думаю, что это может быть связано с PTY (терминалом), но не уверен...

Любая помощь/подсказки будут очень признательны!