узел чтения потокового файла с удаленного компьютера с использованием ssh - PullRequest
Новая
       17

узел чтения потокового файла с удаленного компьютера с использованием ssh

1 голос
/ 21 мая 2019

Я пытаюсь прочитать данные в потоке из файла журнала удаленного сервера, который постоянно растет.Я хочу отобразить новые строки, добавленные в мою локальную консоль.Я использую SSH для подключения с локального на удаленный сервер.

Я нашел решение на github, который записывает содержимое локального файла в удаленный файл, но я хочу другим способом.Не получается преобразовать это в обратном направлении. 

var Connection = require('ssh2');
var fs = require('fs');
var BufferedStream = require('buffered-stream');

console.log('sshstream started')
connectSSH();

function readFile(filepath, startOffset, outputStream) {
    var fileSize = fs.statSync(filepath).size;
    var length = fileSize - startOffset;
    var myFD = fs.openSync(filepath, 'r');
    var readable = fs.createReadStream(filepath, {
        fd: myFD, start: startOffset, end: fileSize, autoClose: true
    })
    return readable;
}
function connectSSH(){
    var c = new Connection();
    c.on('connect', function() {
      console.log('Connection :: connect');
    });
    c.on('ready', function() {
      console.log('Connection :: ready');
      c.shell('', function(err, stream) {
        if (err) throw err;         
        stream.on('data', function(data, extended) {
          console.log((extended === 'stderr' ? 'STDERR: ' : 'STDOUT: ')
                      + data);
        });
        stream.on('end', function(code, signal) {
          console.log('Stream :: EOF', code, signal);
        });
        stream.on('close', function(code, signal) {
          console.log('Stream :: close', code, signal);
        });
        stream.on('exit', function(code, signal) {
          console.log('Stream :: exit :: code: ' + code + ', signal: ' + signal);
          c.end();
        });
        stream.on('drain', function() {
          console.log('Stream :: drain');
        });       
            var bufferStream = new BufferedStream(4*1024*1024);
            bufferStream.pipe(stream);
            stream.write('cat - >> /home/username/mylog.log');
            readable = readFile('test.log', 0, bufferStream);
            readable.once('end', function(){
                    console.log("ENDED");
            });
            readable.pipe(bufferStream).pipe(stream);           
        });
    });
    c.on('error', function(err) {
      console.log('Connection :: error :: ' + err);
    });
    c.on('end', function() {
      console.log('Connection :: end');
    });
    c.on('close', function(had_error) {
      console.log('Connection :: close');
    });
    c.connect({
      host: 'xx.xxx.xx.xxx',
      port: 22,
      username: 'username',
      password: 'password'   
    });
}

Пожалуйста, предложите Спасибо

1 Ответ

1 голос
/ 21 мая 2019

Это работает, и его можно настроить по вашему желанию. 

'use strict';

const SSH = require('simple-ssh');

function run(sshConfig, script) {
  return new Promise((resolve, reject) => {
    let scriptOutput = '';
    const sshFtw = new SSH(sshConfig);
    sshFtw.exec(script,
      { out: console.log.bind(console) })
      .on('error', (err) => reject(err))
      .on('close', () => resolve(scriptOutput))
      .start();
  });
};


run({
  "host": "1.2.3.4",
  "user": "my-user",
  "pass": "my-psw"
}, 'tail -f /home/my-app/log/api-out.log');
...