1

Сервис запущен в asyncio event_loop, через Popen запускаются дочерние процессы. Как получить информацию, о том, что процесс завершился без опроса состояния по интервалу. Нужно решение возможностями subprocess.

1
  • у него похоже синхронный попен.
    – eri
    6 окт 2017 в 7:41

1 ответ 1

0

subprocess только если опрашивать в отдельном треде и синхронизировать ,например, семафором.

Если сервис на asyncio, то есть смысл поработать и ним.

Для калбэков рекомендую использовать asyncio.SubprocessProtocol для обработки подпроцессов в asyncio. Вместо popen теперь loop.subprocess_exec()

Протокол реализуется таким образом(пример из документации):

import asyncio
import sys

class DateProtocol(asyncio.SubprocessProtocol):
    def __init__(self, exit_future):
        self.exit_future = exit_future
        self.output = bytearray()

    def pipe_data_received(self, fd, data):
        self.output.extend(data)

    def process_exited(self):
        self.exit_future.set_result(True)

@asyncio.coroutine
def get_date(loop):
    code = 'import datetime; print(datetime.datetime.now())'
    exit_future = asyncio.Future(loop=loop)

    # запускает питон с кодом
    # Create the subprocess controlled by the protocol DateProtocol,
    # redirect the standard output into a pipe
    create = loop.subprocess_exec(lambda: DateProtocol(exit_future),
                                  sys.executable, '-c', code,
                                  stdin=None, stderr=None)
    transport, protocol = yield from create

    # Wait for the subprocess exit using the process_exited() method
    # of the protocol
    yield from exit_future

    # Close the stdout pipe
    transport.close()

    # Read the output which was collected by the pipe_data_received()
    # method of the protocol
    data = bytes(protocol.output)
    return data.decode('ascii').rstrip()

if sys.platform == "win32":
    loop = asyncio.ProactorEventLoop()
    asyncio.set_event_loop(loop)
else:
    loop = asyncio.get_event_loop()

date = loop.run_until_complete(get_date(loop))
print("Current date: %s" % date)
loop.close()

exit_future используется для индикации завершения процесса - блокирует до завершения процесса.

process_exited - нужный Вам калбак. Чтоб не опрашивать состояние, он выполнится по завершении процесса.

7
  • такие сложности совсем ни к чему. В asyncio у дочернего процесса также есть communicate() метод. Вот пример кода. Так как не ясно, что конкретно у автора вопроса есть и что он хочет получить, то следовало бы вместо ответа, который не ясно на какой вопрос отвечает, оставить комментарий к вопросу оставить с просьбой уточнить и проголосовать о закрытии как "неясный вопрос", как я это сделал (сейчас комментарии удалены, по вашей просьбе).
    – jfs
    9 окт 2017 в 6:30
  • Ответ на вопрос "как повесить калбак на попен?"
    – eri
    23 окт 2017 в 11:40
  • у вас в ответе нет subprocess.Popen. Если вы решили игнорировать одни требования в вопросе, но не другие (используя вероятно искусство чтения мысли, чтобы угадать, что автор действительно хочет: "Нужно решение возможностями subprocess."), то по крайней мере приводите адекватное решение для задачи, которую вы сами выбрали. Если ваша задача: прочитать, используя asyncio цикл, вывод из внешней команды, то следует начинать с самого простого метода, который работает (communicate()) и только если появятся дополнительные требования, тогда уже усложнять.
    – jfs
    23 окт 2017 в 11:56
  • Некоторые требования не всегда выполнимы. Ответ с 0 лучше чем отсутствие ответов.
    – eri
    23 окт 2017 в 13:42
  • усложнённый вариант в ответе вводит в заблуждение (так как есть проще решения, если мы самостоятельно требования выбираем). Лучше если нет ответа, чем тот ответ, который в заблуждение вводит.
    – jfs
    23 окт 2017 в 13:44

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge you have read our privacy policy.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.