Описание тега node.js-stream

1 ответ

Удалить заголовки из потокового HTTP-потока

Чтобы дать краткий пример того, чего я хочу достичь, представьте, что у нас есть HTTP-сервер, уже обслуживающий данный запрос: require('http').createServer(function(req, res) { var payload = new Buffer('Hello World\n', 'utf8'); res.writeHead(200, { …
22 мар '15 в 20:02
1 ответ

node.js http.IncomingMessage не запускает событие 'close'

Когда http.IncomingMessage запускает событие 'close'? Согласно документации это должно произойти, когда нижележащее соединение было закрыто. Однако он никогда не вызывается для следующего примера кода (я убедился, что он не вызван keep-alive): var h…
20 ноя '13 в 13:26
2 ответа

NODEJS: метод Uncork() в записываемом потоке на самом деле не сбрасывает данные

Я пишу довольно простое приложение для преобразования данных - читать один файл и писать в другой. Файлы относительно большие - 2 Гб. Однако то, что я обнаружил, это то, что сброс в файловую систему не происходит, в цикле cork-uncork он происходит т…
20 янв '16 в 14:22
1 ответ

Определить, когда данные прошли через цепочку потоков без завершения цепочки

Я передаю несколько файлов через поток шифров, а затем записываю результат в один и тот же файл. Я могу сделать это, делая src_file_1.pipe(cipher, {end: false}).pipe(dest_file, {end: false});, src_file_2.pipe(cipher, {end: false}).pipe(dest_file, {e…
29 авг '16 в 19:36
0 ответов

Узел JS Express Framework потоковое видео не работает во второй раз

Попытка реализовать приложение, где пользователь может выбрать и воспроизвести любое видео из списка. Для первого запуска это работает очень гладко, потоковая передача и все, но как только я нажимаю кнопку "Выйти" или "Вернуться" и воспроизводить др…
11 окт '18 в 18:12
1 ответ

Узел fs.readstream() выводит <Buffer 3c 3f 78 6d 6c...> вместо читаемых данных

Я читаю большой XML-файл (~1,5 ГБ) в Node Js. Я пытаюсь транслировать его и что-то делать с кусками данных, но мне трудно понять документацию. Мой текущий простой код: var fs = require('fs'); var stream = fs.createReadStream('xml/bigxmlfile.xml'); s…
16 дек '13 в 02:46
1 ответ

node.js createWriteStream не создает новый файл в Heroku

У меня есть следующий код, который отлично работает на моем localhost работает node.js 0.12.0. Код создает новый файл и копирует данные из удобочитаемого, но не создает новый файл в Heroku. var output = fs.createWriteStream('public/images/test/testf…
27 май '15 в 19:53
1 ответ

Трансформировать поток, получая доступ к внутренним данным

Я хочу прочитать файл (в идеале с fs.createReadStream, передать его через процесс преобразования, а затем записать его (в идеале, используя fs.createWriteStream) в другой файл. Я использую поток преобразования (new stream.Transform()) для этого и вр…
20 мар '16 в 22:35
0 ответов

Проблемы с разработкой музыкального потокового сервера с помощью node.js, AWS

Я занимаюсь разработкой сервера музыкальных потоков с помощью node.js, AWS(Elastic beanstalk и S3) У меня есть две проблемы... когда я видел журнал Elastic beanstalk (работающий на сервере node.js), возникает ошибка "errorTimeoutError: время соедине…
1 ответ

Как я могу прочитать поток объектов JSON в браузер

Учитывая node.js поток объекта стиля, как показано в примере ниже, как это может быть прочитано http запрос на сайте и обработан: {"id":"one", "value":"the first object"} {"id":"two", "value":"the second object"} {"id":"three", "value":"the third ob…
2 ответа

Как правильно завершить поток Gulp?

Я конвертирую задачу сборки Grunt в реализацию Gulp. я использую gulp-watchи вот что я придумал для запуска своих задач: gulp.task('task', function(){ return watch('glob/**/*', function(){ var stream = doTask(); return stream; }) }); Проблема в том,…
16 окт '15 в 19:02
0 ответов

NodeJS / ECONNRESET приводит к ошибке при получении удаленного CSV-файла

Это мой первый вопрос здесь. Я сделаю все возможное. Прежде всего, я начну с моих пакетов, которые я использую для решения задачи. Node v8.10.0 NPM-Packages for this Task requestretry(copy of request, with customizable retry attempts on errors) Link…
0 ответов

Запись MediaStream на стороне сервера (с видео и аудио) из WebRTC в файл

Я разрабатываю приложение, целью которого является потоковое видео (со звуком) с камеры (мобильное приложение) и сохранение его на диске (на сервере). Все с коммуникацией между клиентом и сервером в порядке. Я использую WebRTC. Одним из пиров являет…
1 ответ

Запись в поток непосредственно перед тем, как событие 'end' запущено

Я использую несколько child_process с родительским процессом Node.js и передаю все stderr из дочерних процессов в файл. Вот так: const strmPath = path.resolve(projRoot + '/suman/stdio-logs/runner-stderr.log'); const strm = fs.createWriteStream(strmP…
21 апр '16 в 03:24
0 ответов

Проблема с ручным завершением потока, доступного для записи, с { end: false } в конвейере

Поэтому ниже приведен код, использующий пользовательский поток, который расширяет поток. Преобразование из базовой библиотеки узла. Целью этого кода является чтение файла строка за строкой, каждая строка представляет собой строку, отформатированную …
25 янв '19 в 04:23
1 ответ

Чтение строк или всего буфера из stdin (node.js)

Я разрабатываю интерактивный консольный интерфейс в node.js, который анализирует и компилирует ввод. Для этого я использую readline.question: require('readline').question('&gt; ', processCommandFunction) Теперь программа также должна иметь возможнос…
18 фев '15 в 14:10
1 ответ

Node.js: переменная, действующая как имя вложенного элемента для объекта

Вот мой объект: obj = { "FirstName": "Fawad", "LastName": "Surosh", "Education": {"University": "ABC", "Year": "2012"} } Вот мой код node.js: var nodeName = 'Education.Year'; obj.nodeName; //this should return the value of Year which is '2012' Есть …
0 ответов

Используя axios, чтобы получить внешнее изображение и затем сохранить его в файловой системе?

У меня есть следующая функция, которая вызывается при каждом запросе. async function checkForNewData() { var now = moment(); var lastUpdateUnix = fs.readFileSync('.data/last-update.txt').toString(); var lastUpdate = moment.duration(lastUpdateUnix, '…
11 янв '19 в 17:34
3 ответа

Как мне закрыть поток, в котором больше нет данных для отправки в node.js?

Я использую node.js и читаю ввод с последовательного порта, открывая файл /dev/tty, отправляю команду и читаю результат команды и хочу закрыть поток после прочтения и анализа всех данных, Я знаю, что я закончил чтение данных и конец маркера данных. …
14 ноя '13 в 13:54
1 ответ

Событие для чтения нода stdin не вызвано

readable событие не инициируется в process.stdin test.js var self = process.stdin, data ; self.on('readable', function() { var chunk = this.read(); if (chunk === null) { handleArguments(); } else { data += chunk; } }); self.on('end', function() { co…
18 авг '13 в 05:11