【发布时间】:2020-04-22 21:49:07
【问题描述】:
我想。 G。读取“tcpdump”打印出来的第一行:
tcpdump: listening on eth0, link-type EN10MB (Ethernet), capture size 262144 bytes
使用“ptyprocess”(上下文:本地进程,涉及终端)和select()超时等待新数据:
import logging
from ptyprocess import PtyProcess
from select import select
logging.basicConfig(
level=logging.DEBUG,
format="%(asctime)s %(name)s %(message)s")
pty_process = PtyProcess.spawn(
argv=["sudo", "tcpdump", "-w", "capture.pcap", "-i", "enp0s3"],
echo=True)
while True:
rlist, _, _ = select([pty_process.fd], [], [], 1)
if pty_process.fd in rlist:
try:
data = pty_process.read(1)
except EOFError:
logging.debug("EOF")
break
logging.debug("read: %r", data)
else:
logging.debug("timeout")
对于 Python 3.x(使用 3.6.10 和 3.8.1 测试),此代码读取由“tcpdump”打印的上述行。
对于 Python 2.x(使用 2.7.17 测试),此代码仅读取第一个字符“t”,然后 select() 超时。我还观察到,第一次运行时,读取了多个字符,但不是全部。
在 Debian 10 上测试。
在读取 Python 2 中的下一个字符之前,如何使用带有“ptyprocess”超时(或类似内容)的 select() 来等待新数据?
更新 1:
strace 显示以下区别:
Python 2:
select(6, [5], [], [], {tv_sec=1, tv_usec=0}) = 1 (in [5], left {tv_sec=0, tv_usec=999993})
read(5, "tcpdump: listening on enp0s3, li"..., 8192) = 86
Python 3:
select(6, [5], [], [], {tv_sec=1, tv_usec=0}) = 1 (in [5], left {tv_sec=0, tv_usec=999994})
read(5, "t", 1) = 1
我。 e.对于 Python 2,调用 read(..., 8192),对于 Python 3,调用 read(..., 1)。我怎样才能实现,对于 Python 2 也调用 read(..., 1) ?
更新 2:
问题与“tcpdump”无关,也可以这样重现:
import logging
from ptyprocess import PtyProcess
from select import select
logging.basicConfig(
level=logging.DEBUG,
format="%(asctime)s %(name)s %(message)s")
pty_process = PtyProcess.spawn(
argv=["bash", "-c", "echo 123 ; sleep 3"],
echo=True)
while True:
rlist, _, _ = select([pty_process.fd], [], [], 1)
if pty_process.fd in rlist:
try:
data = pty_process.read(1)
except EOFError:
logging.debug("EOF")
break
logging.debug("read: %r", data)
else:
logging.debug("timeout")
Python 2 输出:
2020-04-23 12:51:27,126 root read: '1'
2020-04-23 12:51:28,193 root timeout
2020-04-23 12:51:29,204 root timeout
2020-04-23 12:51:30,129 root read: '2'
2020-04-23 12:51:30,129 root read: '3'
2020-04-23 12:51:30,129 root read: '\r'
2020-04-23 12:51:30,130 root read: '\n'
2020-04-23 12:51:30,130 root EOF
Python 3 输出:
2020-04-23 12:51:23,106 root read: b'1'
2020-04-23 12:51:23,107 root read: b'2'
2020-04-23 12:51:23,107 root read: b'3'
2020-04-23 12:51:23,107 root read: b'\r'
2020-04-23 12:51:23,107 root read: b'\n'
2020-04-23 12:51:24,109 root timeout
2020-04-23 12:51:25,109 root timeout
2020-04-23 12:51:26,109 root EOF
【问题讨论】:
-
这能回答你的问题吗? Handling tcpdump output in python
-
不管这个问题是否回答了这个问题,使用
Popen和tcpdump -l在两个 Python 版本上都有效,然后如果进入下一个迭代需要超过一秒的时间,您可以终止它在循环中(见答案)。与 python 中的许多事情一样,有多种方法可以做事情,我认为在这种情况下 Popen 更可取。 -
@RossJacobs 我想逐个字符地读取超时,例如。 G。能够执行诸如“读取直到出现超时的特定字符串,稍后继续读取”之类的操作。在这个问题中,我想关注“ptyprocess”(即涉及终端的情况,尽管这里的 tcpdump 可能不需要它)而不是我用于其他情况的“子进程”。
-
您能否在您的问题中更详细地说明为什么此处需要 ptyprocess 以及更广泛的环境上下文(例如,这是在 SSH 连接上并且必须通过伪终端运行)?
-
@RossJacobs 实际上这个问题发生在使用以下 4 种情况的类库开发过程中:1)本地进程,无终端,2)本地进程,终端,3)SSH,无终端,4 ) SSH,终端。这里我们说的是案例2)。
标签: python select timeout pexpect pty