无法从 aws lambda 函数触发 aws sqs
Unable to trigger aws sqs from aws lambda function
我有一个需要触发 aws sqs 的 aws lambda 函数,但我总是收到以下消息:
Fail Send MessageAccessDenied: Access to the resource https://sqs.eu-west-1.amazonaws.com/ is denied
这是我的 lambda:
var QUEUE_URL = 'https://sqs.eu-west-1.amazonaws.com/*****/*****'
var AWS = require('aws-sdk');
var sqs = new AWS.SQS({region : 'eu-west-1'});
exports.handler = function(event, context) {
var params = {
MessageBody: JSON.stringify(event),
QueueUrl: QUEUE_URL
};
sqs.sendMessage(params, function(err,data){
if(err) {
console.log('error:',"Fail Send Message" + err);
context.done('error', "ERROR Put SQS"); // ERROR with message
} else{
console.log('data:',data.MessageId);
context.done(null,''); // SUCCESS
}
});
}
任何人都知道问题可能是什么或 aws.sqs 的好资源吗?我是否需要传递凭据,以及如何在 aws.sqs 中设置我的队列 url?
您是否为您的 Lambda 函数分配了执行角色,允许它向 SQS 队列发送消息? This article 详细介绍了如何操作,特别是设置 IAM 角色部分。
我有一个需要触发 aws sqs 的 aws lambda 函数,但我总是收到以下消息:
Fail Send MessageAccessDenied: Access to the resource https://sqs.eu-west-1.amazonaws.com/ is denied
这是我的 lambda:
var QUEUE_URL = 'https://sqs.eu-west-1.amazonaws.com/*****/*****'
var AWS = require('aws-sdk');
var sqs = new AWS.SQS({region : 'eu-west-1'});
exports.handler = function(event, context) {
var params = {
MessageBody: JSON.stringify(event),
QueueUrl: QUEUE_URL
};
sqs.sendMessage(params, function(err,data){
if(err) {
console.log('error:',"Fail Send Message" + err);
context.done('error', "ERROR Put SQS"); // ERROR with message
} else{
console.log('data:',data.MessageId);
context.done(null,''); // SUCCESS
}
});
}
任何人都知道问题可能是什么或 aws.sqs 的好资源吗?我是否需要传递凭据,以及如何在 aws.sqs 中设置我的队列 url?
您是否为您的 Lambda 函数分配了执行角色,允许它向 SQS 队列发送消息? This article 详细介绍了如何操作,特别是设置 IAM 角色部分。