Ошибка лямбда-ключа AWS - PullRequest
Новая
       52

Ошибка лямбда-ключа AWS

0 голосов
/ 01 июня 2018

У меня есть лямбда-функция для создания нового AMI и присоединения к текущей группе автоматического масштабирования.Эта функция завершается, когда я создаю пользовательский тестовый пример и передаю полезную нагрузку.Проблема возникает, когда я запускаю это из SNS: 

import json
import boto3
import time
import sys

asObj = boto3.client('autoscaling')
ec2Obj = boto3.client('ec2')

def lambda_handler(event, context):
    targetASG = event[‘Records’][0][‘Sns’][‘Message’]
    ASG = asObj.describe_auto_scaling_groups(AutoScalingGroupNames=[event['targetASG']])
    sourceInstanceId = ASG.get('AutoScalingGroups')[0]['Instances'][0]['InstanceId']
    Date=time.strftime("%d%m%y")
    Time=time.strftime("%H%M%S")
    amiName = "Automated_%s_%s" % (Date, Time)
    configName = "Automated_%s_%s" % (Date, Time)

    CreateNewImage = ec2Obj.create_image(
        InstanceId = sourceInstanceId,
        Name = amiName,
        Description = 'Automatically Created Image from Lambda Service',
        NoReboot = True)
    Image = []
    Image.append(CreateNewImage)
    def getCreatedID(Image):
        for i in Image:
            ID = i['ImageId']
            return ID
    AMINewID = getCreatedID(Image)
    CreateNewConfig = asObj.create_launch_configuration(
        LaunchConfigurationName = configName,
        ImageId = AMINewID,
        InstanceId = sourceInstanceId)

    updateASG = asObj.update_auto_scaling_group(
        AutoScalingGroupName = event['targetASG'],
        LaunchConfigurationName = configName)
    return 'A new AMI has been Created `%s` Updated ASG `%s` with new launch configuration `%s` which includes AMI `%s`.' % (amiName,event['targetASG'], configName, AMINewID)

Для запуска своей лямбда-функции я использую тему AWS SNS и публикую сообщение, следующее сообщение, тип сообщения: raw 

{   "targetASG": "pre-production-xxx" }

Но я получаю эту ошибку:

'targetASG': KeyError Traceback (последний вызов был последним): файл "/var/task/lambda_function.py", строка 13, в lambda_handlerASG = asObj.describe_auto_scaling_groups (AutoScalingGroupNames = [event ['targetASG']]) KeyError: 'targetASG'

Как решить эту проблему?

1 Ответ

0 голосов
/ 01 июня 2018

ASG = asObj.describe_auto_scaling_groups(AutoScalingGroupNames=[event['targetASG']])

Я думаю, targetASG не является частью события SNS. События SNS выглядят так:

{ "Records": [ { "EventVersion": "1.0", "EventSubscriptionArn": "arn:aws:sns:EXAMPLE", "EventSource": "aws:sns", "Sns": { "SignatureVersion": "1", "Timestamp": "1970-01-01T00:00:00.000Z", "Signature": "EXAMPLE", "SigningCertUrl": "EXAMPLE", "MessageId": "95df01b4-ee98-5cb9-9903-4c221d41eb5e", "Message": "Hello from SNS!", "MessageAttributes": { "Test": { "Type": "String", "Value": "TestString" }, "TestBinary": { "Type": "Binary", "Value": "TestBinary" } }, "Type": "Notification", "UnsubscribeUrl": "EXAMPLE", "TopicArn": "arn:aws:sns:EXAMPLE", "Subject": "TestInvoke" } } ] }

Вы должны захватитьсообщение и проанализируйте значение targetASG оттуда, например, 

import json

[...]
targetASG = event[‘Records’][0][‘Sns’][‘Message’]
myMessage = json.loads(targetASG)
name = myMessage['targetASG']
ASG = asObj.describe_auto_scaling_groups(AutoScalingGroupNames=[name])
[...]
...