NodeJS: чтение CSV-файла с sftp-сервера и преобразование его в JSON

Я использую ssh2-sftp-client для чтения файла CSV и создания ReadableStream. Затем я пытаюсь преобразовать этот readableStream в Json с помощью библиотеки csvtojson. Однако я всегда получаю следующую ошибку:

TypeError: readStream.pipe не является функцией

Вот мой код:

let Client = require('ssh2-sftp-client');
let sftp = new Client();
var csv = require("csvtojson");

sftp.connect({
    host: 'HOST',
    port: 'PORT',
    username: 'USERNAME',
    password: 'PASSWORD'
}).then(() => {
    return sftp.get('/home/user/etc/testfile.csv');
}).then((data) => {
    csv()
        .fromStream(data)
        .subscribe(function (jsonObj) { //single json object will be emitted for each csv line
            // parse each json asynchronousely
            return new Promise(function (resolve, reject) {
                resolve()
                console.log(jsonObj);
            })
        })

}).catch((err) => {
    console.log(err, 'catch error');
});

Кто-нибудь знает, правильно ли я использую обе библиотеки или невозможно то, чего я пытаюсь достичь?


node.js sftp ssh2-sftp
person threxx    schedule 18.03.2019    source источник

Ответы (1)


arrow_upward
6
arrow_downward

Вы получаете сообщение об ошибке, потому что sftp.get возвращает Buffer, а вы пытаетесь передать его функции, которая ожидает Stream.

Измените свой код на этот

let Client = require('ssh2-sftp-client');
let sftp = new Client();
var csv = require("csvtojson");

sftp.connect({
  host: 'HOST',
  port: 'PORT',
  username: 'USERNAME',
  password: 'PASSWORD'
}).then(() => {
  return sftp.get('/home/user/etc/testfile.csv');
}).then((data) => {
  csv()
    .fromString(data.toString()) // changed this from  .fromStream(data)
    .subscribe(function(jsonObj) { //single json object will be emitted for each csv line
      // parse each json asynchronously
      return new Promise(function(resolve, reject) {
        resolve()
        console.log(jsonObj);
      })
    })
}).catch((err) => {
  console.log(err, 'catch error');
});
person Benjie Wheeler    schedule 18.03.2019
comment
Я пытаюсь сделать то же самое, но понятия не имею, что анализировать после .Subscribe .. // асинхронно анализировать каждый json ... если кто-нибудь будет достаточно любезен, дайте мне знать пример :) - person Jim Dover; 04.08.2021