我有一个 apiGateway 端点,我正在向端点发送一些发布请求。apigateway 的集成类型是 lambda 函数。我希望 lambda 函数监听来自 apigateway 的发布数据并将这些数据推送到 kinesis firehose。
谁能帮我获取一个示例节点 js lambda 代码,它将把传入的数据推送到 kinesis firehose。我试图搜索这个,但什么也得不到。
谢谢
我有一个 apiGateway 端点,我正在向端点发送一些发布请求。apigateway 的集成类型是 lambda 函数。我希望 lambda 函数监听来自 apigateway 的发布数据并将这些数据推送到 kinesis firehose。
谁能帮我获取一个示例节点 js lambda 代码,它将把传入的数据推送到 kinesis firehose。我试图搜索这个,但什么也得不到。
谢谢
我得到了它。
这是一个示例代码:
var AWS = require('aws-sdk');
var firehose = new AWS.Firehose();
exports.handler = function(event, context) {
var params = {
DeliveryStreamName: <STRING>,
Record: {
Data: decodeURIComponent(event)
}
};
firehose.putRecord(params, function(err, data) {
if (err) console.log(err, err.stack); // an error occurred
else console.log(data); // successful response
context.done();
});
};