節點JS刪除目錄中的舊文件

Question

我想達到一定的限度後刪除目錄中的一些文件。（比如刪除文件，如果文件大於20的號碼）

請將任何自動化可以是偉大的完成刪除這些文件。

詳細內容： 在我的情況下，有一個uploads目錄，我在上傳圖片。對於每個新圖像，都會創建一個目錄並將圖像駐留在目錄中。所以我想保留一些新創建或最近使用的目錄，並在某個限制之後刪除其他目錄（例如達到20個目錄後）。在創建新圖像時，它會檢查限制，如果超出最大限制，它將刪除未使用的目錄。

注意：目錄不是空的。

我該怎麼做，使用Node.js

任何幫助將是可觀的。

Answer 1

你可能會考慮設置一個KUE任務： https://github.com/learnboost/kue

苦厄（或在它的頂部上有輕微的包裝/ MOD）很可能是什麼使得它成爲核心我們的計劃作業的道路。

Answer 2

如果您在Linux服務器上運行節點，則可以使用exec模塊執行Linux命令。例如，下面是我用移動舊的日誌文件的函數：

var exec = require('child_process').exec; 

exec('mv ' + __dirname + '/log/*.log ' + __dirname + '/log/archive', 
    function(err, stdout, stderr) { 
     if (err) { 
      console.log('Error archiving log files: ' + stderr); 
     } else { 
      console.log('Log files archived to ' + __dirname + '/log/archive'); 
     } 
}); 

你可以使用任何Linux命令 - 所以你可以使用這個方法來刪除的文件。

Answer 3

最廣泛使用的技術將是有一個API可以刪除文件夾中的文件。看看

fs.unlink 

你可以得到更多的細節here

一旦你有了這個API，最好每隔一個月左右有一個cron調用這個API。看看

crontab -e 

Answer 4

我創造的Node.js一 「的cronjob」 功能的文件夾中刪除文件（注意子文件夾將被忽略）

用法：

// keep only 5 newest files in `logs` folder 
watchAndRemoveOldFiles('logs', 5, function (err, removeFiles) { 
    console.log('These files has been remove:', removeFiles); 
}); 

Full code（您需要npm install async來運行代碼）：

var fs = require('fs'); 
var path = require('path'); 
var async = require('async'); 

function findAndRemoveOldFiles(inputDir, keepCount, callback) { 
    if(!callback) { 
     callback = function (err, removeFiles) { 
      // default callback: doing nothing 
     }; 
    }; 

    fs.readdir(inputDir, function (err, files) { 
     if(err) { 
      return callback(err); 
     } 

     fileNames = files.map(function (fileName) { 
      return path.join(inputDir, fileName); 
     }); 

     async.map(fileNames, function (fileName, cb) { 
      fs.stat(fileName, function (err, stat) { 
       if(err) { 
        return cb(err); 
       }; 

       cb(null, { 
        name: fileName, 
        isFile: stat.isFile(), 
        time: stat.mtime, 
       }); 
      }); 
     }, function (err, files) { 

      if(err) { 
       return callback(err); 
      }; 

      files = files.filter(function (file) { 
       return file.isFile; 
      }) 

      files.sort(function (filea, fileb) { 
       return filea.time < fileb.time; 
      }); 

      files = files.slice(keepCount); 

      async.map(files, function (file, cb) { 
       fs.unlink(file.name, function (err) { 
        if(err) { 
         return cb(err); 
        }; 

        cb(null, file.name); 
       }); 
      }, function (err, removedFiles) { 
       if(err) { 
        return callback(err); 
       } 
       callback(null, removedFiles); 
      }); 
     }); 
    }); 
} 

function watchAndRemoveOldFiles(inputDir, keepCount, callback) { 
    findAndRemoveOldFiles(inputDir, keepCount, callback); 
    fs.watch(inputDir, function() { 
     findAndRemoveOldFiles(inputDir, keepCount, callback); 
    }); 
} 

// USAGE: watch and remove old files, keep only 5 newest files 
watchAndRemoveOldFiles('log', 5, function (err, removeFiles) { 
    console.log('These files has been remove:', removeFiles); 
});