为aws lambda函数传递查询参数
passing query params for aws lambda function
我正在尝试设置一个Lambda函数,该函数将提取传递到创建的API网关URL中的查询参数。(边栏:在编程方面,我仍然很幼稚,所以请原谅我无意中对如何命名感到困惑)。我已经使用Synchronize.JS在光纤中封装了一些REST调用,当我将要传递的变量硬编码到各种RESTurl中时,它非常有效,但我们的目标是能够传递不同的参数,这些参数将作为正在进行的不同REST调用的全局变量。这就是我目前拥有的。。。
// Dependendies
var request = require('superagent');
var sync = require('synchronize');
exports.handler = function(event, context) {
sync.fiber(function() {
var followingArray = [];
var followersArray = [];
var postsCountArray = [];
var allSqorCountArray = [];
var trendingPostAuthorArray = [];
var hashtagCountArray = [];
var notificationCountArray = [];
var getParam = function(query){
var SearchString = window.location.search.substring(1);
var VariableArray = SearchString.split('&');
for(var i = 0; i < VariableArray.length; i++){
var KeyValuePair = VariableArray[i].split('=');
if(KeyValuePair[0] == query){
return KeyValuePair[1];
}
};
};
var userId = getParam('userId');
var limit = getParam('limit');
var offset = getParam('offset');
var restCallOne = function() {
request('https://someurl.com/etc/' + userId + '/follows?limit=' + limit + '&offset=' + offset)
.end(function(err, res) {
if (err) {
console.log('Request 1');
context.fail("Danger Will Robinson!!! Follows Count Does Not Like You!!");
} else {
var followsCount = res.body.total_count;
followingArray.push(followsCount);
}
});
};
var restCallTwo = function() {
request
.get('https://someurl.com/etc/etc/etc?limit=' + limit + '&offset=' + offset)
.set({'access-token': 'someAccessToken'})
.end(function(err, res) {
if(err) {
console.log('Request 4');
context.fail("Danger Will Robinson!! The All Sqor Feed is moody");
} else {
var allSqorCount = res.body.total_count;
allSqorCountArray.push(allSqorCount);
}
});
};
var restCallThree = function() {
request
.get('https://someUrl.com/etc/' + userId + '/followers?limit=' + limit + '&offset=' + offset)
.end(function(err, res) {
if (err) {
console.log('Request 3');
context.fail("Danger Will Robinson!!! Following Count Done Smacked You Upside The Head!!");
} else {
var count = res.body.total_count;
followersArray.push(count);
context.done(null, 'The total number of people that follow Andy is ' + followersArray[0] +
', and the number of people that Andy follows is ' + followingArray[0] +
', and the number of posts in his feed is ' + allSqorCountArray[0]);
}
});
};
try {
restCallOne(userId, limit, offset);
} catch(errOne) {
console.log("Error on call 1!!");
}
try {
restCallTwo(limit, offset);
} catch(errTwo) {
console.log("Error on call 2!!");
}
try {
restCallThree(userId, limit, offset);
} catch(errThree) {
console.log("Error on call 3!!");
}
});
};
当我将其与此函数链接时生成的API网关URL如下:https://someID.execute-api.us-east-1.amazonaws.com/syncFunctionalParams
但我希望能够传入这样的内容,并使用Lambda函数中的params从其余调用中返回正确的信息:https://someID.execute-api.us-east-1.amazonaws.com/syncFunctionalParams?userId=212733&limit=25&偏移=0
这可能吗??我是不是偏离了轨道?
您需要在API网关中设置一个映射模板。如果你提前知道你的参数名称,你的模板可能是这样的:
{
"userId": "$input.params('userId')",
"limit": "$input.params('limit')",
"offset": "$input.params('offset')"
}
其中,每个$input.params('...')
都将被求值,并且当事件传递给Lambda时,查询字符串中的值将被放在它的位置。
如果您不提前知道参数名称,您将不得不在Lambda中进行一些解析。您的映射模板如下所示:
{
"querystring": "$input.params().querystring"
}
在传递给Lambda的事件中,最终会变成这样:
{
"querystring": "{limit=25, offset=0, userId=212733}"
}
然后在getParam()
中解析event.querystring
而不是window.location.search
。显然,您需要更改一些逻辑,因为您将使用逗号而不是"与"分隔,并且您需要去掉花括号。顺便说一句,由于此时您在服务器上,因此没有window
对象。
- 如何将参数赋予作为查询参数的参数值给定的函数
- 具有可选'/'s和查询参数
- 如果没有Ember中的控制器,我如何更改查询参数
- 如何编码&在不是't是查询参数的一部分
- 如何在JavaScript中传递查询参数和重定向
- React 路由器和任意查询参数:页面在加载时无意中刷新
- MongoDB查找查询参数
- 布尔查询参数被 Sails.js 视为字符串
- jQuery脚本,它搜索现有的查询参数并且不添加“"如果存在
- 基于查询参数的可选承诺步骤
- 如何使用Backbone.Return捕获查询参数的更改
- 在iron router中使用查询参数修改模板
- 如何将查询参数设置为我的所有路线,当它改变时-在恩伯
- 如何使用查询参数在jQuery中生成url
- Javascript/jQuery URL查询参数解析
- Ember.js查询参数不尊重replace:true并使用replaceState
- jQuery将查询参数附加到当前哈希中,忽略重复项
- window.location.href未设置查询参数
- 如何在angular中访问URL中的查询参数(在hash之外,非html 5模式)
- 获取具有主干木偶查询参数的当前 URL