Вопросы по теме 'nodejs-stream'
process.stdout.write / process.stderr.write monkey-patch работает в дочернем процессе, но не в родительском
Итак, у меня есть этот простой обезьяний патч на process.stdout.write / process.stderr.write
const strm = fs.createWriteStream(logfile);
const stdoutWrite = process.stdout.write;
process.stdout.write = function () {...
435 просмотров
schedule
09.04.2023
Потоковая передача больших статических файлов с использованием NodeJS
Мне нужно периодически использовать большие неформатированные текстовые файлы только для чтения и проверять наличие определенного содержимого/слов в каждом из этих файлов. Этот файл состоит из всех буквенно-цифровых символов. Однако у меня возникают...
145 просмотров
schedule
20.03.2023
Стратегия в Nodejs для объединения нескольких читаемых потоков
Я пытаюсь решить проблему с потоком Nodejs. Я читал документацию по потокам несколько раз и реализовал разные попытки решить эту проблему. Пробуем как с дуплексом, так и с преобразованием, с возможностью чтения и записи :)
У меня есть несколько...
311 просмотров
schedule
02.05.2023
Как создать поток чтения из байтов в памяти?
Все примеры создания потока, с которыми я сталкивался, сосредоточены вокруг файла. Я работаю с интерфейсом, который требует, чтобы я передал поток чтения потоку записи. Мой ввод - это необработанные байты, которые у меня есть в памяти, а не файл....
4319 просмотров
schedule
16.02.2023
_read() не реализован в читаемом потоке
Этот вопрос заключается в том, как на самом деле реализовать метод чтения читаемого потока.
У меня есть эта реализация читаемого потока:
import {Readable} from "stream";
this.readableStream = new Readable();
я получаю эту ошибку...
14597 просмотров
schedule
09.02.2023
Nodejs Transform - можно ли считать обратный вызов перед отправкой хорошей практикой?
Что касается функции преобразования stream.Transform: Это нормально, поскольку она не сломает что-то вроде механизма обратного давления, и, предполагая, что меня не волнует порядок, чтобы вызвать callback() перед вызов push(), чтобы я мог асинхронно...
150 просмотров
schedule
15.10.2022
Цепочка потоков Nodejs
Привет, я хотел бы связать несколько файловых потоков чтения, мое текущее использование примерно такое;
создать дочерний процесс
создать файлReadStream
отправить содержимое файла через канал (child.stdin)
вернуться к шагу 2
Я пытаюсь...
868 просмотров
schedule
20.04.2024
Невозможно установить заголовки после того, как они будут отправлены на клиентскую ошибку при потоковой передаче ответа с помощью res.write
Я пытаюсь передать ответ от экспресса, используя метод res.write. Ниже мой код, я получаю сообщение об ошибке «Невозможно установить заголовки после их отправки клиенту», когда я попадаю на сервер. Я пытаюсь передать каждую запись массива. Может...
63 просмотров
schedule
07.11.2022
Получение незапрошенного ввода в NodeJS
Я пытаюсь получить незапрошенный ввод от пользователя на сервере NodeJS. Причина в том, что я хочу иметь возможность отправлять строки, которые можно интерпретировать как команды во время работы сервера, например команды для очистки кеша....
194 просмотров
schedule
13.08.2022
Код Node js, в котором я хочу научиться работать с асинхронным кодом
setTimeout(()=>{
console.log('time out')
},3000)
}
go();
console.log('app')
Это асинхронный код, я хочу распечатать приложение после задержки, но, как мы знаем, сначала печатается «приложение», а затем «тайм-аут».
72 просмотров
schedule
07.07.2023
Потоковое аудио с сервером NodeJs
Я работаю над аудиоприложением в прямом эфире. Для этого я использую сервер NodeJs, который содержит список песен, которые я хочу транслировать, когда клиент отправляет запрос. Все работает хорошо, но когда я хочу начать песню с определенной точки...
107 просмотров
schedule
03.05.2023
Использование RabbitMQ с узлом — ограничение параллельной обработки
У меня есть очередь RabbitMQ, которая иногда может содержать значительный объем данных для обработки.
Насколько я понимаю, использование channel.consume попытается принудительно отправить сообщения в программу Node, даже если она достигает своего...
151 просмотров
schedule
29.01.2023
Функция Firebase Node.js преобразует поток
Я создаю HTTP-функцию Firebase, которая выполняет запрос BigQuery и возвращает измененную версию результатов запроса. Запрос потенциально возвращает миллионы строк, поэтому я не могу сохранить весь результат запроса в памяти, прежде чем ответить...
188 просмотров
schedule
17.03.2023
Как передать данные, измененные из потока gunzip, в поток gzip?
Мне нужно запустить через HTTP-запрос процесс, в котором я загружаю некоторые данные из S3, архивирую их, изменяю поток, сжимаю его и отправляю в другое ведро в S3.
Пока я мог:
Скачать
Gunzip
Изменить (отфильтровать) данные
вернуть данные...
42 просмотров
schedule
26.05.2022
Инициировать загрузку файла HTTP, прочитав файл из другого HTTP-запроса, состоящего из нескольких частей.
Конечная точка загрузки получает данные от клиента в составном файле. Этот файл снова отправляется в качестве параметра для нового HTTP-вызова, сделанного из той же службы.
//Клиент загружает код файла...
99 просмотров
schedule
15.03.2023
Как прочитать файл из интерфейса NAPI (node-addon) и записать в другой файл, используя файловый поток nodejs
Я пытаюсь прочитать файл в приложении NAPI и вызвать функцию обратного вызова, чтобы записать его в поток записи в приложении nodejs.
exmaple_Class.cpp
void readFromTransientFile(const Napi::CallbackInfo &info)
{
Napi::Env env =...
226 просмотров
schedule
02.07.2023
как создать читаемый поток с удаленного URL-адреса в nodejs?
в документации nodejs в разделе потоков говорится, что я могу сделать fs.createReadStream(url || path) . Но, когда я действительно это делаю, Он говорит мне Error: ENOENT: no such file or directory . Я просто хочу передать видео из читаемого в...
3542 просмотров
schedule
21.09.2022
