将 S3 对象的内容流式传输到哈希算法 node.js

Question

我是 node.js 的新手，我正在尝试编写一个 AWS lambda 函数，该函数将 s3 对象的内容流式传输到节点的加密模块中，以创建 s3 对象的 md5 校验和值。不知道为什么，但每次我运行代码时，它都会在 console.log 上生成不同的哈希值。谁能指出我正确的方向来修复我的代码？感谢您的帮助！

var crypto = require('crypto');
var fs = require('fs');
var AWS = require('aws-sdk'); 
var s3 = new AWS.S3(); 

exports.handler = (event, context, callback) => {

 var params = {
    Bucket: 'bucket_name',
    Key: 'key', 
 };

var hash = crypto.createHash('md5');
var stream = s3.getObject(params, function(err, data) {
  if (err){
    console.log(err);
    return;
  }
}).createReadStream();

stream.on('data', function (data) {
    hash.update(data, 'utf-8')
})

stream.on('end', function () {
    console.log(hash.digest('hex'))
})

};

Answer 1

你很接近。您将“回调”样式方法签名与“createReadStream”签名混合在一起。尝试这个：

const crypto = require('crypto');
const fs = require('fs');
const AWS = require('aws-sdk');
const s3 = new AWS.S3();

exports.handler = (event, context, callback) => {
  let params = {
    Bucket: 'bucket_name',
    Key: 'key',
  };

  let hash = crypto.createHash('md5');
  let stream = s3.getObject(params).createReadStream();
  stream.on('data', (data) => {
    hash.update(data);
  });

  stream.on('end', () => {
    let digest = hash.digest('hex');
    console.log(digest);
    callback(null, digest);
  });
};