Lambda(Python3.8)のKeyError:Records解消方法

Question

前提・実現したいこと

URL先のようなS3内のログをSplunkに流す構成（S3→SNS→SQS①→Lambda→SQS②→Splunk）の中にLambdaを構築したいと考えています。
https://github.com/pauld-splunk/aws-s3-sqs-lambda

発生している問題・エラーメッセージ

SQS①から受け取ったキューをLambda（Python3.8）にて複数のSQSにルーティングするためサイト内のコードをコピペし環境変数とIAMロールを設定しDeployしたところ以下のようなKeyErrorが発生してしまいました。

{
  "errorMessage": "'Records'",
  "errorType": "KeyError",
  "stackTrace": [
    "  File \"/var/task/lambda_function.py\", line 7, in lambda_handler\n    sqs_records = event[\"Records\"]\n"
  ]
}

該当のソースコード

import json
import boto3
import os
sqs = boto3.client('sqs')
def lambda_handler(event, context):
    
    sqs_records = event["Records"]

    try:
        excludelist=json.loads(os.environ['EXCLUDELIST'])
    except:
        excludelist=[]

    for payload_record in sqs_records:
        
        body = json.loads(payload_record['body']) 

        try:
            message = json.loads(body['Message'])
        except:
            message = []

        s3_records = message["Records"]


        for s3_record in s3_records:
            mykey = s3_record["s3"]["object"]["key"]
            arn = s3_record["s3"]["bucket"]["arn"]

            skip=0
            for item in excludelist:
                if (item in mykey):
                    skip=1
                    print(f'Not forwarding object <{mykey}> from bucket <{arn}> as it is in exclude list')
                    
            
            if ("CloudTrail" in mykey):
                forwardQueue = sqs.get_queue_url(QueueName=os.environ['CloudTrailQueueName'])
            elif ("Config" in mykey):
                forwardQueue = sqs.get_queue_url(QueueName=os.environ['ConfigQueueName'])
            elif ("vpcflowlogs" in mykey):
                forwardQueue = sqs.get_queue_url(QueueName=os.environ['vpcflowlogsQueueName'])
            else:
                forwardQueue = sqs.get_queue_url(QueueName=os.environ['defaultQueueName'])
            
            if skip!=1:
                forwardQueueUrl = forwardQueue['QueueUrl']
                sqs.send_message(QueueUrl=forwardQueueUrl, MessageBody=(json.dumps(body)))

試したこと

調べた中でKeyErrorはキーが存在しないという記述が多かったためスペルミスや括弧の表記が間違っている可能性を考慮し変更してテストしてみましたがエラーが解消されませんでした。

補足情報

18-21行目箇所

        try:
            message = json.loads(body['Message'])
        except:
            message = []

は別のエラーが発生していたためtry-exceptを追加しました。

Answer 1

テストイベント自体がデフォルトとなっていたためキーが存在するはずがなかったです。失礼いたしました。