Вопросы по теме 'node-streams'

дождаться окончания всех потоков - передать каталог файлов
Я использую client.upload в pkgcloud , чтобы загрузить каталог файлов. Как я могу выполнить обратный вызов после завершения всех потоков? Есть ли встроенный способ зарегистрировать событие завершения каждого потока и выполнить обратный вызов...
11539 просмотров
schedule 26.05.2024

Gulp смотреть с browserSync
Я пытаюсь написать файл gulp, который делает следующее: Запускает задачу наблюдения, которая перестраивает шаблоны Handlebars при любом изменении шаблона. Если сборка завершается неудачно, она уведомляет BrowserSync с помощью метода notify(),...
257 просмотров
schedule 05.12.2022

Как читать из одного потока и писать сразу в несколько?
Предположим, у меня есть поток readable , например. request(URL) . А я хочу записать свой ответ на диск через fs.createWriteStream() и пайпинг с запросом. Но в то же время я хочу посчитать контрольную сумму загрузки данных через поток...
208 просмотров
schedule 17.03.2023

Обработка ошибок потоковой передачи/конвейера Node.js (изменение статуса ответа при ошибке)
У меня есть миллионы строк в моей базе данных Cassandra, которые я хочу передать клиенту в виде zip-файла (не хочу потенциально огромного zip-файла в памяти). Я использую функцию stream() из драйвера Cassandra-Node, направляя ее в Transformer,...
1395 просмотров

Как записать массив JSON в файл с помощью Node.js writeStream?
Я написал небольшой скрипт Node.js для очистки данных с веб-сайта, на котором я перебираю страницы для извлечения структурированных данных. Данные, которые я извлекаю для каждой страницы, представляют собой массив объектов. Я подумал, что могу...
3883 просмотров
schedule 15.11.2022

Сохраняет ли write() (без обратного вызова) порядок в потоках записи node.js?
У меня есть программа node.js, в которой я использую поток для записи информации на SFTP-сервер. Примерно так (упрощенный вариант): var conn = new SSHClient(); process.nextTick(function (){ conn.on('ready', function () {...
588 просмотров
schedule 12.07.2023

Эффективное чтение, обработка и вставка данных с помощью PG-Promise и PG-Query-Stream
Я собираюсь сделать следующее. Запросите большую таблицу с группой по запросу, чтобы выполнить суммирование значений. Запустите эти записи через процедуру, чтобы добавить некоторые дополнительные данные. Эффективно вставьте их в БД. Я...
963 просмотров
schedule 06.12.2022

Загрузите большой поток в S3 с помощью aws lambda
Когда я пытаюсь прочитать данные и загрузить их в поток данных с помощью лямбда-функции aws, когда размер потока составляет 250 МБ или 300 МБ, загрузка zip-файла будет успешной за одну минуту, но размер потока составляет 400 МБ или 500 МБ, функция...
1662 просмотров

Зачем мне нужен обратный вызов в моем методе .write() для потокового API?
Этот вопрос касается обратного вызова в методе Writable.write потокового API node.js. Я изучаю потоки node.js, используя stream-adventure, который по сути является интерактивным учебным пособием для потоков. Одно из заявлений о проблеме состоит в...
29 просмотров
schedule 19.04.2023

NodeJS: получить имя файла из readStream
TLDR; Могу ли я получить имя файла из читаемого потока? У меня есть способ загрузить файл с Google Диска и сохранить его в локальный каталог, поскольку я запрашиваю ответ в виде потока. Я хотел бы сохранить файл с тем же именем, что и на диске, без...
187 просмотров

Невозможно установить currentTime для аудиопотока (socket-io-stream)
Я передаю аудиофайл с помощью socket-io-stream и node.js с сервера в браузер. Это работает хорошо, но я хотел бы изменить свойство currentTime элемента audio. Я не уверен, но кажется, что браузер не может воспроизводиться после получения...
11 просмотров

Как использовать await/async в fs.createReadStream/csv-parser с помощью промисов?
Я попытался реализовать этот код из Human Who Codes , вместе с методом запуска из этого ответа для чтения CSV с URL-адресами креативов, загрузите этот креатив с медиасервера, а затем загрузите SDK Node.js для креатива Facebook. Однако у меня...
171 просмотров
schedule 02.02.2024