如何将 Python 的 cmd 类的输入/输出通过管道传输到另一个 Python 进程？

Posted 2023-02-23

【中文标题】如何将 Python 的 cmd 类的输入/输出通过管道传输到另一个 Python 进程？

【英文标题】：How to pipe a Python's cmd class' input/output to another Python process?

【发布时间】：2016-09-30 08:27:55

【问题描述】：

目前，我正在使用Mininet-Wifi 进行实验。它的 CLI 是 Python 的 Cmd 模块，这就是我能够获得有关模拟网络环境的准确信息的方式。模拟器在 Ubuntu 14.04 或更高版本上作为 sudo python 作为自己的进程运行。

此网络的遥控器是POX。这一次，只有一个脚本在运行；一切都是通过预设命令自动化的——不再需要人工交互。我想做的是：POX 进程需要将命令注入 Mininet 的进程并检索该命令的执行结果。这是因为 POX 的逻辑必须不断地通过 Mininet 查询网络状态才能做出决策。做出决定后，POX 必须再次向 Mininet 进程注入命令以更改网络状态。

补充：目前，我只能在运行 sudo python a_mininet_script 时访问由 Mininet 生成的主机，这要归功于名为 m 的实用程序函数。生成主机后，Mininet 进入其 CLI 功能，这是我想与之通信但不能通信的功能。这是 Mininet 的 m 函数。

#!/bin/bash
# Attach to a Mininet host and run a command

if [ -z $1 ]; then
  echo "usage: $0 host cmd [args...]"
  exit 1
else
  host=$1
fi

pid=`ps ax | grep "mininet:$host$" | grep bash | grep -v mnexec | awk 'print $1;'`

if echo $pid | grep -q ' '; then
  echo "Error: found multiple mininet:$host processes"
  exit 2
fi

if [ "$pid" == "" ]; then
  echo "Could not find Mininet host $host"
  exit 3
fi

if [ -z $2 ]; then
  cmd='bash'
else
  shift
  cmd=$*
fi

cgroup=/sys/fs/cgroup/cpu/$host
if [ -d "$cgroup" ]; then
  cg="-g $host"
fi

# Check whether host should be running in a chroot dir
rootdir="/var/run/mn/$host/root"
if [ -d $rootdir -a -x $rootdir/bin/bash ]; then
    cmd="'cd `pwd`; exec $cmd'"
    cmd="chroot $rootdir /bin/bash -c $cmd"
fi

cmd="exec sudo mnexec $cg -a $pid $cmd"
eval $cmd

例如，要从任何终端访问 h1 的终端，而不是从 POX 脚本，我会这样称呼它：

sh m h1 ifconfig

但要从 subprocess 调用它，它会是：

p = subprocess.Popen('echo my passwd | sudo -kS sh m h1 ifconfig', shell = True)

重复我的问题，我想从 POX 控制器与 Mininet 进程的 CLI 进行通信，而不仅仅是生成的主机。

【参考方案1】：

我猜你想实现类似 netstat -oan | 的功能。 findstr 80（这是在 windows 上查找端口 80），这是将 netstat -oan 的输出传递给命令 findstr 的管道命令。

那么python代码是这样的：

import subprocess

p1 = subprocess.Popen('netstat -oan', stdout=subprocess.PIPE, shell=True)
p2 = subprocess.Popen('findstr 80', stdin=p1.stdout, stdout=subprocess.PIPE, shell=True)
pipeline_output = p2.communicate()[0]
print pipeline_output

然后，p1 进程的输出将传递给 p2 进程，仅供参考。