Tag: 亚马逊kinesis

Amazon Kinesis NodeJS – putRecord操作到期

我使用NodeJS和Express作为代理来处理HTTP GET请求，做一些小的数据适配，并将数据提交给Amazone Kinesis。 这里是我的代码摘录： var express = require('express'); var app = express(); app.get('/proxy-test', function(req, res){ var data = req.query; // perform some light data processing // send results to kinesis kinesis.putRecord({ StreamName : MY_STREAM_NAME, Data : data, PartitionKey : MY_PARTITION_KEY }, function(err, data) { if (err) { console.log(err, err.stack); // an error occurred } else […]