node.js - AWS-SDK崩溃Node.js程序

我正在将aws-sdk用于javascript。

在独立程序中使用以下代码时，效果很好

//program.js

const AWS = require('aws-sdk');
const firehose = new AWS.Firehose({
   accessKeyId: "XXX",
  secretAccessKey: "YY"
});

const params = {
  DeliveryStreamName: 'demo1',
  Record: {
    Data: new Buffer("Hello World")
  }
};

firehose.putRecord(params, function (err, data){
  if (err) {
    console.log(err);
    return;
  }
  console.log(data);           // successful response
});

同样，以上代码可以作为独立文件正常工作。数据被放入防火墙，然后进一步移至Redshift。
所以如果我执行

node program.js

我可以在Redshift中查看我的数据。好极了！！

============================

但是，我真正想要实现的是在我的快速应用程序中遇到某条路由时将数据推送到firehose。所以我采用与上面完全相同的代码并将其粘贴在我的路线中

// router.js
const AWS = require('aws-sdk');
const firehose = new AWS.Firehose({
   accessKeyId: "XXX",
  secretAccessKey: "YY"
});

router
  .get('/v1/locations/:id?', (req, res) => {

   const params = {
     DeliveryStreamName: 'demo1',
     Record: {
        Data: new Buffer("Hello World")
     }
   };

    firehose.putRecord(params, function (err, data){
     if (err) {
       console.log(err);
       return;
     }
      console.log(data);

    });

   // do the work that needs to be done for this route and send a response
   res.send("some data");

  });

分钟firehose.putRecord被执行..它使我的程序崩溃，并显示以下错误：

```

TypeError: doneCallback.cal is not a function
    at Request.callListeners (/api-project/node_modules/aws-sdk/lib/sequential_executor.js:115:18)
    at callNextListener (/api-project/node_modules/aws-sdk/lib/sequential_executor.js:95:12)
    at /api-project/node_modules/aws-sdk/lib/event_listeners.js:74:9
    at finish (/api-project/node_modules/aws-sdk/lib/config.js:315:7)
    at /api-project/node_modules/aws-sdk/lib/config.js:333:9
    at Credentials.get (/api-project/node_modules/aws-sdk/lib/credentials.js:126:7)
    at getAsyncCredentials (/api-project/node_modules/aws-sdk/lib/config.js:327:24)
    at Config.getCredentials (/api-project/node_modules/aws-sdk/lib/config.js:347:9)
    at Request.VALIDATE_CREDENTIALS (/api-project/node_modules/aws-sdk/lib/event_listeners.js:69:26)
    at Request.callListeners (/api-project/node_modules/aws-sdk/lib/sequential_executor.js:101:18)

我不明白为什么这段代码会使我的Express程序崩溃。这是aws-sdk库中的错误，还是我做错了什么？

最佳答案

您应该在成功回调中发送快速响应。

firehose.putRecord(params, function (err, data) {
   if (err) {
     console.log(err);
     return;
   }
    console.log(data);
    res.send("some data");
  }
);