当文件中有更新时，如何从nodejs中的fs.watch获取更新的数据

Question

我正在尝试从文件中获取更新的数据，当我使用 fs.watch 来观察更改时，我正在尝试从文件中获取更新的数据，但是如何获取更新的数据以便我可以将 csv 解析为 json

nodejs代码：

var express=require("express");
var app=express();

var http = require('http');
var fs = require('fs');
 var Converter = require("csvtojson").Converter;
var converter = new Converter({constructResult:false});

fs.createReadStream("test.xlsx").pipe(converter);
//record_parsed will be emitted each csv row being processed 
converter.on("record_parsed", function (jsonObj) {
   console.log(jsonObj); //here is your result json obje

app.get("/",function(req,res)
{
 console.log("listening\n");
 fs.watch('test.csv', function (event, filename) {
  console.log('event is: ' + event);

//record_parsed will be emitted each csv row being processed 
converter.on("record_parsed", function (jsonObj) {
   console.log(jsonObj); //here is your result json object 
});
});

});

 app.listen(8180);
 console.log("running");

Answer 1

您可以考虑使用tail-stream 或至少看看它的源代码。

它扩展stream.Readable 并在change 事件发生时使用fs.watch 执行stream.read(0)。尽管如此，如果您决定自己实现它，还有很多工作要正确处理 EOF、文件删除等。