Дочерний процесс Node.js для процесса Python

Я должен отправить текст из дочернего процесса node.js в процесс python. Мой клиент фиктивного узла выглядит так

var resolve = require('path').resolve;
var spawn = require('child_process').spawn;

data = "lorem ipsum"

var child = spawn('master.py', []);

var res = '';
child.stdout.on('data', function (_data) {
    try {
        var data = Buffer.from(_data, 'utf-8').toString();
        res += data;
    } catch (error) {
        console.error(error);
    }
});
child.stdout.on('exit', function (_) {
    console.info("EXIT:", res);
});
child.stdout.on('end', function (_) {
    console.info("END:", res);
});
child.on('error', function (error) {
    console.error(error);
});

child.stdout.pipe(process.stdout);

child.stdin.setEncoding('utf-8');
child.stdin.write(data + '\r\n');

в то время как процесс Python master.py

#!/usr/bin/env python

import sys
import codecs

if sys.version_info[0] >= 3:
    ifp = codecs.getreader('utf8')(sys.stdin.buffer)
else:
    ifp = codecs.getreader('utf8')(sys.stdin)

if sys.version_info[0] >= 3:
    ofp = codecs.getwriter('utf8')(sys.stdout.buffer)
else:
    ofp = codecs.getwriter('utf8')(sys.stdout)

for line in ifp:
    tline = "<<<<<" + line + ">>>>>"
    ofp.write(tline)

# close files
ifp.close()
ofp.close()

Я должен использовать кодированный входной считыватель utf-8, поэтому я использую sys.stdin, но кажется, что когда node.js записывает в дочерний процесс stdin с помощью child.stdin.write(data + '\r\n');, это не будет прочитано sys.stdin в for line in ifp:

Почему в Python есть оператор "pass"?
Почему в Python есть оператор "pass"?
Оператор pass в Python - это простая концепция, которую могут быстро освоить даже новички без опыта программирования.
Некоторые методы, о которых вы не знали, что они существуют в Python
Некоторые методы, о которых вы не знали, что они существуют в Python
Python - самый известный и самый простой в изучении язык в наши дни. Имея широкий спектр применения в области машинного обучения, Data Science,...
Основы Python Часть I
Основы Python Часть I
Вы когда-нибудь задумывались, почему в программах на Python вы видите приведенный ниже код?
LeetCode - 1579. Удаление максимального числа ребер для сохранения полной проходимости графа
LeetCode - 1579. Удаление максимального числа ребер для сохранения полной проходимости графа
Алиса и Боб имеют неориентированный граф из n узлов и трех типов ребер:
Оптимизация кода с помощью тернарного оператора Python
Оптимизация кода с помощью тернарного оператора Python
И последнее, что мы хотели бы показать вам, прежде чем двигаться дальше, это
Советы по эффективной веб-разработке с помощью Python
Советы по эффективной веб-разработке с помощью Python
Как веб-разработчик, Python может стать мощным инструментом для создания эффективных и масштабируемых веб-приложений.
0
0
1 156
1
Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Вам нужно будет вызвать child.stdin.end() в программе Node после последнего вызова child.stdin.write(). Пока не будет вызван end(), доступный для записи поток child.stdin будет хранить записанные данные в буфере, поэтому программа Python их не увидит. Подробности см. в обсуждении Буферизация в https://nodejs.org/docs/latest-v8.x/api/stream.html#stream_buffering.

(Если вы записываете много данных в stdin, то буфер записи в конечном итоге заполнится до точки, где накопленные данные будут автоматически сброшены в программу Python. Затем буфер снова начнет собирать данные. Вызов end() необходим для выполнения Убедитесь, что последняя часть записанных данных сброшена. Это также дает указание дочернему процессу, что больше данные не будут отправляться в этом потоке.)

Спасибо, это правильно. Предположим, что я хотел бы оставить stdin открытым, чтобы я мог сделать несколько child.stdin.write, как я могу принудительно сбросить буфер, чтобы питон отправлял обратно накопленные данные?

loretoparisi 16.02.2019 16:58

Для этого я создал специальный вопрос: stackoverflow.com/questions/54725072/…

loretoparisi 16.02.2019 17:16

Другие вопросы по теме