Описание тега transform-stream
Относится к функциям потока преобразования NodeJS, форме функции потока "дуплекс", которая изменяет передаваемые данные.
2
ответа
Как использовать преобразование узла для преобразования одного объекта в другой
Я новичок в потоках Node и пытаюсь понять, почему все работает не так, как ожидалось. Я просто тренируюсь и хочу сделать глупое преобразование. interface MyTransformStreamOptions { [key: string]: any } class MyTransformStream extends Transform { con…
09 апр '18 в 02:19
1
ответ
Обтекание потока nodejs в объекте JSON
У меня есть читаемый поток, что-то вроде этого: const algorithm = 'aes-256-ctr'; stream = file.stream .pipe(crypto.createCipher(algorithm, encryptionKey)) .pipe(outStream); Шифрование работает, как и ожидалось, для всего файла. Мне нужно обернуть ре…
09 окт '17 в 19:33
1
ответ
Проблема во время тестирования transform-streams (Node.js) с Benchmark.js
Я пытаюсь тестировать код NodeJS, но получаю следующую ошибку: events.js:167 throw er; // Unhandled 'error' event ^ Error [ERR_STREAM_WRITE_AFTER_END]: write after end at writeAfterEnd (_stream_writable.js:243:12) at Transform.Writable.write (_strea…
04 дек '18 в 21:19
1
ответ
Как получить поток NodeJS Transform для создания нескольких записей для каждого блока ввода?
Я пишу поток Transform, который принимает входящий поток XML и передает его подмножество в виде объектов JS. <item> <name>some name</name> <files> <file path='path/to/file'/> <file path='path/to//other/file'/> <…
28 июн '17 в 14:05
2
ответа
Как написать асинхронную функцию, которая разрешается при срабатывании генератора событий `data`
Я использую node-serialport для связи с частью оборудования. Он просто пишет команду и получает ответ. https://serialport.io/docs/en/api-parsers-overview Следующий код работает: const port = new SerialPort(path); const parser = port.pipe(new Readlin…
12 ноя '18 в 19:43
0
ответов
Управление выполнением потока преобразования NodeJS
У меня есть база кода, где я собираю несколько потоков преобразования в NodeJS stream.on('data',function(data){}).pipe(data_work1).pipe(data_work2).pipe(data_work3).pipe(insertDataIntoDB); Работает нормально. Мой вопрос касается дизайна, когда исход…
15 май '19 в 20:29
2
ответа
Откажитесь от чанка в потоке NodeJS Transform и прочитайте следующий
Как мне отбросить кусок в потоке преобразования NodeJS и прочитать следующий из предыдущего потока? stream.on('data',function(data){}).pipe(rulesCheck).pipe(step1).pipe(step2).pipe(step3).pipe(insertDataIntoDB); Я хотел бы отказаться от чанка, если …
07 июн '19 в 19:57
0
ответов
Как вы оборачиваете записи sequelize, которые происходят в STREAM node.js в транзакции?
Я проверяю файлы CSV и затем записываю их в базу данных. Текущая настройка - File.pipe(validationStream).pipe(DBWriteStream); Как можно обернуть все записи в моем DBWriteStream в транзакцию, которую можно отменить, если в validationStream обнаружены…
11 июл '19 в 21:48
0
ответов
Как добавить строку в начало и конец файла потока?
const origin = npm.fs.createReadStream(req.files.info.tempFilePath, { flags: 'r', encoding: 'utf8' }); const transform = new npm.stream.Transform({ // accept data as a strings writableObjectMode: true, transform: (chunk, encoding, callback) => {…
15 ноя '19 в 18:25
0
ответов
как создать множественный поток из исходного потока на основе некоторого фильтра в nodejs
Я хочу создать несколько потоков из одного потока на основе фильтров и хочу прослушивать эти потоки в каком-то другом модуле, который когда-либо его слушает. В основном я экспортирую поток, но я не могу слушать его в другом классе, который мне в осн…
14 дек '19 в 02:30
0
ответов
Инвертирование буфера изображений - NodeJS
Я пытаюсь инвертировать пиксели изображения. У меня есть простой поток преобразования для передачи буфера из потока чтения в поток записи. В настоящее время реализация преобразования выглядит так: Inversion.prototype._transform = function(chunk, enc…
27 мар '20 в 09:40
0
ответов
Передача потока через посредника перед передачей по конвейеру другому потоку
Я пишу приложение Express, которое подключается к AWS S3. Одна конечная точка извлекает файлы из корзины S3 и затем отправляет их клиенту с помощью res. Так выглядит этот обработчик const handler = (req, res) => { const s3Stream = awsS3.getObject…
18 авг '20 в 13:19
1
ответ
Алгоритм Хаффмана с потоком в Node JS
Я реализовал алгоритм Хаффмана в Node JS, и он выглядит так: huffman.encode(inputFilename, outputFilename) huffman.decode(inputFilename, outputFilename) Но я хочу реализовать это так: inputStream.pipe(HuffmanEncoderStream).pipe(outputStream) outputS…
27 сен '20 в 22:36
1
ответ
Сервер Shopify не позволяет полную загрузку файла
Я закодировал страницу с помощью webpack и интегрировал ее в магазин shopify. Сайт работает нормально на моем локальном сервере, но не на серверах shopify. Проблема связана с этой частью: return fetch(filePath) // Retrieve its body as ReadableStream…
10 авг '21 в 22:23
1
ответ
NodeJS net.socket Pipe по условию/фильтру
Я новичок в NodeJS. Существующий канал net.socket необходимо фильтровать по условию, чтобы не подключаться к «con2», мой существующий код выглядит следующим образом. Я нашел методы Transform и PipeLine, и пока я пробовал, пример кода еще не работает…
12 янв '22 в 12:38
1
ответ
Два заблуждения по поводу части потока преобразования документации node.js в стиле до ES6
Вот документ , с которым я смущен. При использовании конструкторов в стиле до ES6 const { Transform } = require('stream'); const util = require('util'); function MyTransform(options) { if (!(this instanceof MyTransform)) return new MyTransform(optio…
05 фев '22 в 21:44
0
ответов
Выдача ошибки из потока преобразования Node.js
Мне нужно выдать ошибку в потоке Transform. Обычно я делаю это с функцией обратного вызова в . Я не могу в своей ситуации, потому что мне нужно выдать ошибку, даже если в данный момент через мой поток не проходят данные. То есть, если данные не пере…
22 мар '22 в 03:31
0
ответов
Как можно программно применить обратное давление с помощью javascript TransformStream?
Согласно спецификации для TransformStreams на https://streams.spec.whatwg.org/#pipe-chains нам говорят следующее: Как только цепочка каналов построена, она будет распространять сигналы о том, как быстро по ней должны проходить фрагменты. Если какой-…
11 сен '22 в 16:02
0
ответов
Порожденный процесс ffmpeg в потоке преобразования nodejs с управлением потоком не обрабатывает входной поток
Я реализовал класс потока преобразования node.js, который порождает ffmpeg и передает преобразованный поток с контролируемой скоростью в реальном времени. Ниже мой метод _transform(). this.rcvd += chunk.length console.log('received bytes %d', this.r…
30 сен '22 в 22:39
0
ответов
Как легко преобразовать поток JSON в NDJSON
Как преобразовать поток ответов на выборку, в котором загружаемый документ имеет формат JSON, в поток NDJSON? Например, этот код: const response = await fetch(url); ndjsonStreamer = ndjsonStream(response.body).getReader(); хорошо работает для URL-ад…
26 апр '23 в 17:21