Wie Sie Zugriff auf das event-Objekt mit python in AWS Lambda?

Follow-up auf diese Frage:
Filter CloudWatch Logs zu extrahieren Instanz-ID

Ich denke, es bleibt die Frage unvollständig, weil es nicht sagen, wie man Zugriff auf das event-Objekt mit python.

Mein Ziel ist:

Lesen Sie die Instanz, die ausgelöst wurde durch eine änderung in den running-Zustand
bekommen Sie einen tag-Wert zugeordnet ist, die Instanz
starten alle anderen Instanzen, die den gleichen tag

Den Cloudwatch-trigger-Ereignis:

{
  "source": [
    "aws.ec2"
  ],
  "detail-type": [
    "EC2 Instance State-change Notification"
  ],
  "detail": {
    "state": [
      "running"
    ]
  }
}

Ich sehe Beispiele wie diese:

def lambda_handler(event, context):

    # here I want to get the instance tag value
    # and set the tag filter based on the instance that 
    # triggered the event

    filters = [{
            'Name': 'tag:StartGroup',
            'Values': ['startgroup1'] 
        },
        {
            'Name': 'instance-state-name', 
            'Values': ['running']
        }
    ]

    instances = ec2.instances.filter(Filters=filters)

Kann ich sehen das event-Objekt, aber ich nicht sehen, wie drill-down in der tag des die Instanz, die hatte es Status auf "running" gewechselt.

Bitte, was ist das Objekt, Attribut, durch das ich kann einen tag von der Instanz ausgelöst?

Ich vermute, es ist so etwas wie:

myTag = event.details.instance-id.tags["startgroup1"]

InformationsquelleAutor Chrisjx | 2017-09-14

0

In den Detailbereich der Veranstaltung, erhalten Sie die Instanz-Id ist. Mithilfe der Instanz-id und AWS-SDK können Sie die Abfrage der tags. Im folgenden wird die Beispiel-Ereignis -
```
{
  "version": "0",
  "id": "ee376907-2647-4179-9203-343cfb3017a4",
  "detail-type": "EC2 Instance State-change Notification",
  "source": "aws.ec2",
  "account": "123456789012",
  "time": "2015-11-11T21:30:34Z",
  "region": "us-east-1",
  "resources": [
    "arn:aws:ec2:us-east-1:123456789012:instance/i-abcd1111"
  ],
  "detail": {
    "instance-id": "i-abcd1111",
    "state": "running"
  }
}
```
Danke, Vaisakh. Dass tatsächlich viel hilft. Ich sehe das event-Objekt und den detail-Abschnitt, aber bitte, wie kommt man zu einem bestimmten tag, mit python, für diese Instanz-id. Dies ist ein json-parsing-übung? Oder kann das getan werden, mit Objekt-Attribute? Der tag-Wert für die Instanz wird nicht angezeigt, um in das event-Objekt. Vielen Dank, Chris.

InformationsquelleAutor Vaisakh PS
0

Die event-Daten an der Lambda enthält die Instanz-ID.

Müssen Sie dann anrufen describe_tags() abrufen, ein Wörterbuch des tags.
```
import boto3
client = boto3.client('ec2')

client.describe_tags(Filters=[
        {
            'Name': 'resource-id',
            'Values': [
                event['detail']['instance-id']
            ]
        }
    ]
)
```
John, ich sah, Verweise auf das client-Objekt in der boto3 docs aber nicht sehen, die describe_tags Methode. Ich habe meine arbeiten (vielleicht nicht das beste ist) - code. Es arbeitet schnell, obwohl es wirft einen Fehler, wenn ich den test mit einer nicht existierenden Instanz-id. Ich denke, das ist OK, weil ich wahrscheinlich nicht starten Sie eine Instanz aus der instanzliste, die nicht vorhanden ist. Wir werden tatsächlich, ich nehme an, dass es beendet werden kann, noch in der Liste, und ich zufällig wählen Sie es. Oh, gut.

InformationsquelleAutor John Rotenstein

Dies ist, was ich kam mit...

Bitte lassen Sie mich wissen, wie man es besser machen kann. Vielen Dank für die Hilfe.

# StartMeUp_Instances_byOne
#
# This lambda script is triggered by a CloudWatch Event, startGroupByInstance.
# Every evening a separate lambda script is launched on a schedule to stop
# all non-essential instances.
# 
# This script will turn on all instances with a LaunchGroup tag that matches 
# a single instance which has been changed to the running state.
#
# To start all instances in a LaunchGroup, 
# start one of the instances in the LaunchGroup and wait about 5 minutes.
# 
# Costs to run: approx. $0.02/month
# https://s3.amazonaws.com/lambda-tools/pricing-calculator.html
# 150 executions per month * 128 MB Memory * 60000 ms Execution Time
# 
# Problems: talk to chrisj
# ======================================

# test system
# this is what the event object looks like (see below)
# it is configured in the test event object with a specific instance-id
# change that to test a different instance-id with a different LaunchGroup

# {  "version": "0",
#   "id": "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx",
#   "detail-type": "EC2 Instance State-change Notification",
#   "source": "aws.ec2",
#   "account": "999999999999999",
#   "time": "2015-11-11T21:30:34Z",
#   "region": "us-east-1",
#   "resources": [
#     "arn:aws:ec2:us-east-1:123456789012:instance/i-abcd1111"
#   ],
#   "detail": {
#     "instance-id": "i-0aad9474",  # <---------- chg this
#     "state": "running"
#   }
# }
# ======================================

import boto3
import logging
import json

ec2 = boto3.resource('ec2')

def get_instance_LaunchGroup(iid):
    # When given an instance ID as str e.g. 'i-1234567', 
    # return the instance LaunchGroup.
    ec2 = boto3.resource('ec2')
    ec2instance = ec2.Instance(iid)
    thisTag = ''
    for tags in ec2instance.tags:
        if tags["Key"] == 'LaunchGroup':
            thisTag = tags["Value"]
    return thisTag

# this is the entry point for the cloudwatch trigger
def lambda_handler(event, context):

    # get the instance id that triggered the event
    thisInstanceID = event['detail']['instance-id']
    print("instance-id: " + thisInstanceID)

    # get the LaunchGroup tag value of the thisInstanceID
    thisLaunchGroup = get_instance_LaunchGroup(thisInstanceID)
    print("LaunchGroup: " + thisLaunchGroup)
    if thisLaunchGroup == '':
        print("No LaunchGroup associated with this InstanceID - ending lambda function")
        return

    # set the filters
    filters = [{
            'Name': 'tag:LaunchGroup',
            'Values': [thisLaunchGroup] 
        },
        {
            'Name': 'instance-state-name', 
            'Values': ['stopped']
        }
    ]

    # get the instances based on the filter, thisLaunchGroup and stopped
    instances = ec2.instances.filter(Filters=filters)

    # get the stopped instance IDs
    stoppedInstances = [instance.id for instance in instances]

    # make sure there are some instances not already started
    if len(stoppedInstances) > 0:
        startingUp = ec2.instances.filter(InstanceIds=stoppedInstances).start()

    print ("Finished launching all instances for tag: " + thisLaunchGroup)

InformationsquelleAutor Chrisjx

Schreibe einen Kommentar

Du musst angemeldet sein, um einen Kommentar abzugeben.