在 Python 中,我有一个关于 subprocess.Popen 函数的问题,我的问题是我无法理解连续读取 stdout 流。当我communicate()
在函数结束时使用时,我得到了我喜欢的输出。但是我这里有两个问题。首先,communicate()
在打印任何内容之前缓冲整个输出,并且获得连续输出会很好。其次,我已经阅读了不适用于大数据流的communicate()
文档,在我的场景中就是这种情况。communicate()
#!/usr/bin/python
import os
import sys
from subprocess import *
import itertools
def combinate(hash_mode,hash_file,directory):
erg = Popen(['hashcat', '-a', '0', '-m', hash_mode, hash_file, '-O', '--potfile-disable'],
stdin=PIPE,
stdout=PIPE,
stderr=PIPE,
universal_newlines=True)
file = []
with os.scandir(directory) as listOfEntries:
for entry in listOfEntries:
if entry.is_file() and entry.name is not ".DS_Store":
file.append(open(directory+entry.name).readlines())
file = list(itertools.permutations(file))
for b in range(0, len(file)):
for i in itertools.product(*file[b]):
test = '\n'.join(i).replace("\n", "")
erg.stdin.writelines(test+'\n')
print(erg.communicate()[0])
这是我与交流的输出:
Session..........: hashcat
Status...........: Cracked
Hash.Type........: SHA-512
Hash.Target......: 7ba4e9da57a7d3bd8b1b43c0b028a96d77721f6b33e3b85f0b2...298b56
Time.Started.....: Sat Feb 24 03:52:05 2018 (0 secs)
Time.Estimated...: Sat Feb 24 03:52:05 2018 (0 secs)
Guess.Base.......: Pipe
Speed.Dev.#2.....: 969.7 kH/s (0.13ms)
Recovered........: 1/1 (100.00%) Digests, 1/1 (100.00%) Salts
Progress.........: 384
Rejected.........: 0
Restore.Point....: 0
Candidates.#2....: telefon1telefon3telefon2 -> tasse2tasse3tasse1
这是我的输出,带有一个带有 stdout.readline 的 for 循环:
Session..........: hashcat
Status...........: Running
Hash.Type........: SHA-512
Hash.Target......: 7ba4e9da57a7d3bd8b1b43c0b028a96d77721f6b33e3b85f0b2...298b56
Time.Started.....: Sat Feb 24 04:14:30 2018 (10 secs)
Time.Estimated...: Sat Feb 24 04:14:40 2018 (0 secs)
Guess.Base.......: Pipe
Speed.Dev.#2.....: 0 H/s (0.00ms)
Recovered........: 0/1 (0.00%) Digests, 0/1 (0.00%) Salts
Progress.........: 0
Rejected.........: 0
Restore.Point....: 0
Candidates.#2....: [Copying]
正如你所看到的,我得到了一个输出,但是 hashcat 进程没有得到我的标准输入流或者没有处理它,我不知道为什么。
如何使用我的代码实现连续输出?