0

我正在尝试使用 node.js 的 knox 模块来管理 Amazon S3 存储桶中的一些小文件。一切都可以独立运行：我可以上传文件、下载文件等。但是，我希望能够定期下载文件。当我修改代码以按时间间隔运行时，我将下载的文件附加到前一个实例而不是覆盖。

我不确定我是否在文件写入代码或诺克斯处理代码中犯了错误。我尝试了几种不同的写入方法（writeFile、writeStream 等），并且查看了 knox 源代码。对我来说没有什么明显的问题。这是我正在使用的代码：

knox = require('knox');
fs = require('fs');
var downFile = DOWNFILE;
var downTxt = '';
var timer = INTERVAL;
var path = S3PATH + downFile;
setInterval(function() 
{
        var s3client = knox.createClient(
        {
                key: '********************',
                secret: '**********************************',
                bucket: '********'
        });
        s3client.get(path).on('response', function(response)
        {
                response.setEncoding('ascii');
                response.on('data', function(chunk)
                {
                        downTxt += chunk;
                });
                response.on('end', function()
                {
                        fs.writeFileSync(downFile, downTxt, 'ascii');
                });
        }).end();
},
timer);
4

1 回答 1

1

问题在于您的var downTxt = '';. 这是您将 downTxt 设置为空白的唯一地方，因此每次检索更多数据时，都会将其添加到您在上一个请求中获得的数据中，因为您永远不会清除上一个请求中的数据。最简单的解决方法是将该行移至该行之前setEncoding。

但是，您处理数据的方式过于复杂。试试这样的东西。您不需要每次都重新创建客户端，如果您正在下载非文本文件，设置编码只会破坏事情，并且不会对文本文件产生影响。接下来，您不应该手动收集数据，您可以在收到数据后立即开始将其写入文件。最后，由于 request 是标准流，因此您无需监视 'data' 事件，因为您只需使用pipe.

var knox = require('knox'),
    fs = require('fs'),
    downFile = DOWNFILE,
    timer = INTERVAL,
    path = S3PATH + downFile,
    s3client = knox.createClient({
        key: '********************',
        secret: '**********************************',
        bucket: '********'
    });

(function downloadFile() {
  var str = fs.createWriteStream(downFile);
  s3client.get(path).pipe(str);
  str.on('close', function() {
    setTimeout(downloadFile, timer);
  });
})();
于 2012-02-04T17:51:46.787 回答