node.js - 当文件中有更新时，如何从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、删除文件等还有很多工作要做。