我尝试使用以下代码创建cloudwatch事件规则。但是,它似乎不起作用。我检查了AWS Cloudwaatch事件,并且附带的lambda函数存在该规则。但是,该事件永远不会被触发。如何解决此问题?
async function createCloudWatchEvent(zip){
if(zip){
try{
await putRule(zip);
await putTarget(zip);
} catch (e) {
console.log(`Can't create [${zip}] cloudwatch event`);
}
}
}
function putRule (ruleName) {
let cloudWatchParams = {
Name: ruleName, // required
ScheduleExpression: 'rate(1 minute)',
State: 'ENABLED'
};
return new Promise(resolve => {
cloudwatchevent.putRule(cloudWatchParams, async function(err, data) {
if(err){
console.log(err);
resolve(err);
}else{
console.log('Successfully created rule: ' + ruleName);
resolve();
}
});
});
}
function putTarget (ruleName) {
let cloudWatchParams = {
Rule: ruleName, // required
Targets: [ // required
{
Arn: 'xxxxxxxxxx',
Id: 'Determine_State',
Input: JSON.stringify({zip: ruleName})
}
]
};
return new Promise(resolve => {
// Attach "Determine_State" target to cloudwatch event
cloudwatchevent.putTargets(cloudWatchParams, function(err, data) {
if(err){
console.log(err);
resolve(err);
}else{
console.log('Successfully attached target [' + cloudWatchParams.Targets[0].Id + '] to rule: ' + ruleName);
resolve();
}
});
});
}
我不确定您是否已经知道,您为lambda函数设置的cron时间表是UTC时间。例如,如果您指定下午5点,则是UTC时间下午5点。也许您在执行之前先检查日志。