AWS -Lambda: как работать с событием SNS в python - PullRequest
Новая
       16

AWS -Lambda: как работать с событием SNS в python

0 голосов
/ 02 марта 2020

Как получить имя корзины из события SNS?

Корзина S3 публикует событие в топике SNS c. Этот топи c вызывает лямбду. Мне нужен SNS, потому что какой-то другой процесс также слушает это событие. Поэтому я не могу напрямую вызвать лямбду из S3.

В лямбда-функции я получаю два параметра: event и context Мне нужно получить имя сегмента из события. Я ожидал сделать что-то вроде этого: 

bucket = event['Records'][0]['s3']['bucket']['name']

Но это не работает, потому что в соответствии с Cloudwatch, параметр события выглядит так: 

{
    "Records":[
        {
            "EventSource":"aws:sns",
            "EventVersion":"1.0",
            "EventSubscriptionArn":"arn:aws:sns:eu-central-1:123456:sns-topic-dam-poc-new-import1:823baaf4-93b6-499a-944e-c99e1a6b1fb5",
            "Sns":{
                "Type":"Notification",
                "MessageId":"2330809c-29c4-5826-910d-d64a7ab22247",
                "TopicArn":"arn:aws:sns:eu-central-1:123456:sns-topic-dam-poc-new-import1",
                "Subject":"None",
                "Message":"{\\'Records\\': [{\\'EventSource\\': \\'aws:sns\\', \\'EventVersion\\': \\'1.0\\', \\'EventSubscriptionArn\\': \\'arn:aws:sns:eu-central-1:123456:sns-topic-dam-poc-new-import1:823baaf4-93b6-499a-944e-c99e1a6b1fb5\\', \\'Sns\\': {\\'Type\\': \\'Notification\\', \\'MessageId\\': \\'b611d3b2-a0d4-55fe-af0f-85648ffc2a59\\', \\'TopicArn\\': \\'arn:aws:sns:eu-central-1:123456:sns-topic-dam-poc-new-import1\\', \\'Subject\\': \\'None\\', \\'Message\\': \\'{\\n   \"Records\":[\\n      {\\n         \"EventSource\":\"aws:sns\",\\n         \"EventVersion\":\"1.0\",\\n         \"EventSubscriptionArn\":\"arn:aws:sns:eu-central-1:123456:sns-topic-dam-poc-new-import1:823baaf4-93b6-499a-944e-c99e1a6b1fb5\",\\n         \"Sns\":{\\n            \"Type\":\"Notification\",\\n            \"MessageId\":\"906fd69c-ee31-50f2-8b9d-804910f6fdcd\",\\n            \"TopicArn\":\"arn:aws:sns:eu-central-1:123456:sns-topic-dam-poc-new-import1\",\\n            \"Subject\":\"Amazon S3 Notification\",\\n            \"Message\":\"{\\\\\"Service\\\\\":\\\\\"Amazon S3\\\\\",\\\\\"Event\\\\\":\\\\\"s3:TestEvent\\\\\",\\\\\"Time\\\\\":\\\\\"2020-03-01T18:18:46.898Z\\\\\",\\\\\"Bucket\\\\\":\\\\\"s3-dam-poc-dev-inbox\\\\\",\\\\\"RequestId\\\\\":\\\\\"9534F72BD9216CA8\\\\\",\\\\\"HostId\\\\\":\\\\\"hSPdeBzns8wjrMHqkFJgw1UPMv0aZ/VOsAxw/z9wtboR+TOy8sKSKElDYxm9kszokgPsBU9T1nU=\\\\\"}\",\\n            \"Timestamp\":\"2020-03-01T18:18:47.036Z\",\\n            \"SignatureVersion\":\"1\",\\n            \"Signature\":\"FuoBKJczUXuKJ58d5SdddqnOjMwjxzG2aN+sef/0M5MFsAjRMyCNknvaXVVRrhujK39HouoOoDqyJNFzDWYR3WTYAM0Sqws9wJK9zBV9mxmMYdIurfDmVj4xsF4xuSeaMy4y/VfU2r75DxqhE3MPmA02IuGInGJsmw9CTk+Ao+kdnk/6rJT+Bt3EKK7uKj3kIWYehPDCYKYdzCsDcaP+Aaj2qEhEbkZxdaopB+pHRkMsLhZS/vHcc0Vd1eyZkRYHkxrG4FeKXVZdJT5OGuyixOSWq9YdCBJhWRnq7cRlQnk05WfswWdukOw9yjBkidsT1pJoiBQ==\",\\n            \"SigningCertUrl\":\"https://sns.eu-central-1.amazonaws.com/SimpleNotificationService-a86cb10b4e1f29c941702d7371d28f7b6.pem\",\\n            \"UnsubscribeUrl\":\"https://sns.eu-central-1.amazonaws.com/?Action=Unsubscribe&SubscriptionArn=arn:aws:sns:eu-central-1:123456:sns-topic-dam-poc-new-import1:823baaf4-93b6-499a-944e-c99e1a6b1fb5\",\\n            \"MessageAttributes\":{\\n\\n            }\\n         }\\n      }\\n   ]\\n}\\', \\'Timestamp\\': \\'2020-03-01T21:45:12.192Z\\', \\'SignatureVersion\\': \\'1\\', \\'Signature\\': \\'pt7Mkfo+CB5rsHAnWWB7Kb/LtgBCZSJWc2fLTB84FhZ9/MFUK0pOYmou97dAgn1hdo48JEXnQKpnMN5flmxwGEmG6SPHklnSAgE18a0Bv0qQgzQ1KF9PIY2ulRJiebbuE0gToTlDCgiUGd0OJpZ5Cdr4TSZgOpT4AcDD4NcpGCBKMTRwTcllaQDTNWF2mko9y6iqLp08ptq14qm4ppu9hrdGUU3klxE77Psn+7El6Cv3R8/asdfasdfaksdjhfiqwezhfknabsdfiugasdkf33==\\', \\'SigningCertUrl\\': \\'https://sns.eu-central-1.amazonaws.com/SimpleNotificationService-ashk38dn298djhxo8he2lknfO.pem\\', \\'UnsubscribeUrl\\': \\'https://sns.eu-central-1.amazonaws.com/?Action=Unsubscribe&SubscriptionArn=arn:aws:sns:eu-central-1:123456:sns-topic-dam-poc-new-import1:823baaf4-93b6-499a-944e-c99e1a6b1fb5\\', \\'MessageAttributes\\': {}}}]}",
                "Timestamp":"2020-03-02T00:20:06.458Z",
                "SignatureVersion":"1",
                "SigningCertUrl":"https://sns.eu-central-1.amazonaws.com/SimpleNotificationService-d3iiiffndoendii3mmmdi3.pem",
                "UnsubscribeUrl":"https://sns.eu-central-1.amazonaws.com/?Action=Unsubscribe&SubscriptionArn=arn:aws:sns:eu-central-1:123456:sns-topic-dam-poc-new-import1:823baaf4-93b6-499a-944e-c99e1a6b1fb5",
                "MessageAttributes":{

                }
            }
        }
    ]
}

Я вижу имя корзины в Message Это мой python код: 

import boto3
def newImportHandler(event, context):
    print("__________")
    print(event)
    print("__________")
    simple1 = event['Records'][0]['Sns']['Message']
    print('Simple 1 '+simple1)
    simple2 = simple1['Records'][0]
    print('Simple 2 '+simple2)

simple1 - строка! так что этот код не работает!

1 Ответ

4 голосов
/ 02 марта 2020

Чтобы воспроизвести вашу ситуацию, я сделал следующее:

Лямбда-код у меня работал нормально: 

import json

def lambda_handler(event, context):

    message = json.loads(event['Records'][0]['Sns']['Message'])
    bucket = message['Records'][0]['s3']['bucket']['name'])
    key = message['Records'][0]['s3']['object']['key'])
    ...
...