質問をすることでしか得られない、回答やアドバイスがある。

15分調べてもわからないことは、質問しよう!

新規登録して質問してみよう
ただいま回答率
87.20%
AWS Lambda

AWS Lambdaは、クラウド上でアプリを実行できるコンピューティングサービス。サーバーのプロビジョニングや管理を要せず複数のイベントに対してコードを実行します。カスタムロジック用いた他AWSサービスの拡張やAWSの規模やパフォーマンスを用いたバックエンドサービスを作成できます。

Python

Pythonは、コードの読みやすさが特徴的なプログラミング言語の1つです。 強い型付け、動的型付けに対応しており、後方互換性がないバージョン2系とバージョン3系が使用されています。 商用製品の開発にも無料で使用でき、OSだけでなく仮想環境にも対応。Unicodeによる文字列操作をサポートしているため、日本語処理も標準で可能です。

AWS(Amazon Web Services)

Amazon Web Services (AWS)は、仮想空間を機軸とした、クラスター状のコンピュータ・ネットワーク・データベース・ストーレッジ・サポートツールをAWSというインフラから提供する商用サービスです。

解決済

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

kekke3
kekke3

総合スコア1

AWS Lambda

AWS Lambdaは、クラウド上でアプリを実行できるコンピューティングサービス。サーバーのプロビジョニングや管理を要せず複数のイベントに対してコードを実行します。カスタムロジック用いた他AWSサービスの拡張やAWSの規模やパフォーマンスを用いたバックエンドサービスを作成できます。

Python

Pythonは、コードの読みやすさが特徴的なプログラミング言語の1つです。 強い型付け、動的型付けに対応しており、後方互換性がないバージョン2系とバージョン3系が使用されています。 商用製品の開発にも無料で使用でき、OSだけでなく仮想環境にも対応。Unicodeによる文字列操作をサポートしているため、日本語処理も標準で可能です。

AWS(Amazon Web Services)

Amazon Web Services (AWS)は、仮想空間を機軸とした、クラスター状のコンピュータ・ネットワーク・データベース・ストーレッジ・サポートツールをAWSというインフラから提供する商用サービスです。

1回答

0評価

0クリップ

2221閲覧

投稿2021/10/21 02:23

編集2021/10/21 02:25

前提・実現したいこと

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" ] }

該当のソースコード

Python3.8

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を追加しました。

良い質問の評価を上げる

以下のような質問は評価を上げましょう

  • 質問内容が明確
  • 自分も答えを知りたい
  • 質問者以外のユーザにも役立つ

評価が高い質問は、TOPページの「注目」タブのフィードに表示されやすくなります。

気になる質問をクリップする

クリップした質問は、後からいつでもマイページで確認できます。

またクリップした質問に回答があった際、通知やメールを受け取ることができます。

teratailでは下記のような質問を「具体的に困っていることがない質問」、「サイトポリシーに違反する質問」と定義し、推奨していません。

  • プログラミングに関係のない質問
  • やってほしいことだけを記載した丸投げの質問
  • 問題・課題が含まれていない質問
  • 意図的に内容が抹消された質問
  • 過去に投稿した質問と同じ内容の質問
  • 広告と受け取られるような投稿

評価を下げると、トップページの「アクティブ」「注目」タブのフィードに表示されにくくなります。

まだ回答がついていません

会員登録して回答してみよう

15分調べてもわからないことは
teratailで質問しよう!

ただいまの回答率
87.20%

質問をまとめることで
思考を整理して素早く解決

テンプレート機能で
簡単に質問をまとめる

質問する

関連した質問

同じタグがついた質問を見る

AWS Lambda

AWS Lambdaは、クラウド上でアプリを実行できるコンピューティングサービス。サーバーのプロビジョニングや管理を要せず複数のイベントに対してコードを実行します。カスタムロジック用いた他AWSサービスの拡張やAWSの規模やパフォーマンスを用いたバックエンドサービスを作成できます。

Python

Pythonは、コードの読みやすさが特徴的なプログラミング言語の1つです。 強い型付け、動的型付けに対応しており、後方互換性がないバージョン2系とバージョン3系が使用されています。 商用製品の開発にも無料で使用でき、OSだけでなく仮想環境にも対応。Unicodeによる文字列操作をサポートしているため、日本語処理も標準で可能です。

AWS(Amazon Web Services)

Amazon Web Services (AWS)は、仮想空間を機軸とした、クラスター状のコンピュータ・ネットワーク・データベース・ストーレッジ・サポートツールをAWSというインフラから提供する商用サービスです。