Привет!
На удалённом сервере запускается некий скрипт,
который БЕСКОНЕЧНО логирует результаты своей работы в stdout.
Нужно выловить в этом выводе строку "Processed".
Написал пока так:
import io
import fabric
ssh = fabric.Connection(...)
stream = io.StringIO()
ssh.run("./start.sh", out_stream=stream)
stream.seek(0)
for line in stream.readlines():
if "Processed" in line:
print("Success!")
break
Всё хорошо, но
ssh.run(...) блокирует дальнейшее выполнение (пока работает скрипт).
Беглое гугление привело к subprocess, asyncio и т. д...
Набросайте примерный шаблон как это оптимальней реализовать?
