Я новичок с Python программированием. Я хочу вызвать несколько команд оболочки параллельно и получить их результат, накопленный в одном массиве, как метод javascript promise.all()
.
У меня есть следующий код в Python
import asyncio
import os
commands = [
'netstat -n | findstr 55601',
'dir | findstr portMonitoring.py',
'ssh 10.6.100.192 netstat'
]
async def job(cmd):
# await asyncio.sleep(1)
# return "HEE"
# return os.popen(cmd).read()
process = await asyncio.create_subprocess_exec(
cmd, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.PIPE
)
return await process.communicate()
async def main():
jobs = [job(cmd) for cmd in commands]
done, pending = await asyncio.wait(jobs, return_when=asyncio.FIRST_COMPLETED)
folders = []
[folders.append(d.result()) for d in done]
print("RESULT:", folders)
asyncio.run(main())
Я получаю следующую ошибку и не могу найти решение, пожалуйста, помогите Спасибо.
Traceback (most recent call last):
File "test.py", line 16, in job
cmd, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.PIPE
File "C:\DEV\Python3.7.4\lib\asyncio\subprocess.py", line 217, in create_subprocess_exec
stderr=stderr, **kwds)
File "C:\DEV\Python3.7.4\lib\asyncio\base_events.py", line 1529, in subprocess_exec
bufsize, **kwargs)
File "C:\DEV\Python3.7.4\lib\asyncio\base_events.py", line 458, in _make_subprocess_transport
raise NotImplementedError
NotImplementedError