Я должен отправить текст из дочернего процесса 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:






Вам нужно будет вызвать 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() необходим для выполнения Убедитесь, что последняя часть записанных данных сброшена. Это также дает указание дочернему процессу, что больше данные не будут отправляться в этом потоке.)
Для этого я создал специальный вопрос: stackoverflow.com/questions/54725072/…
Спасибо, это правильно. Предположим, что я хотел бы оставить
stdinоткрытым, чтобы я мог сделать несколькоchild.stdin.write, как я могу принудительно сбросить буфер, чтобы питон отправлял обратно накопленные данные?