NodeJS Datapumps поток из файла - PullRequest
0 голосов
/ 19 июня 2020

Я пытаюсь прочитать файл JSON в насос (https://www.npmjs.com/package/datapumps). На данный момент я просто пытаюсь распечатать на консоли, чтобы увидеть, работает ли он, но ниже не работает, поскольку он говорит, что в буфере ничего нет. Просто нужна еще одна пара глаз, чтобы увидеть, где я ошибаюсь. Конечным результатом является выполнение некоторого преобразования данных и вставка в MongoDb.

const datapumps = require('datapumps')
const fs = require('fs')

const stream = fs.createReadStream('path-to-file.json')

pump = new datapumps.Pump()
pump.from(stream).run()

console.log(pump.buffer())

1 Ответ

1 голос
/ 19 июня 2020

Попробуйте:

const datapumps = require('datapumps');
const fs = require('fs');

const stream = fs.createReadStream('path-to-file.json');

const pump = new datapumps.Pump();

pump.from(stream).run();

const pumpBuffer = pump.buffer();

pumpBuffer.on('sealed', () => {
    const content = pumpBuffer.getContent();
    console.log({ content });
    const oneBuffer = Buffer.concat(content);
    console.log(oneBuffer);
});

Вы можете читать данные в виде буфера и при необходимости преобразовывать их с помощью встроенных Node.js библиотек. Это будет еще проще, потому что у них есть полная документация.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...