質問編集履歴

3

本文を編集しました。本来の目的と該当の事象を追記

2023/01/11 08:30

投稿

msy47
msy47

スコア26

test CHANGED
File without changes
test CHANGED
@@ -13,12 +13,22 @@
13
13
  - [ ] 項目に応じた変換処理をかけOpensearchへ転送したい
14
14
 
15
15
  ### 発生している問題・エラーメッセージ
16
+
17
+ 本Lamda(python)はトリガーを設定しています。
18
+
19
+ 【トリガー】
20
+ S3にcsvがアップロードされることで、Lamda(python)が実行開始される
21
+
16
- S3にアップロードされているcsv
22
+ アップロードるcsv
17
23
  ```
18
24
  vmanage_host, systemip, hostname , devicemodel, bfdSessionsUp, bfdSessions, datetime, IPsecTunnel
19
25
  vmanageABC, 123.456.789.012, vedgeABC, deviceABC, 1, 2, 3, 2022/1/1 01:01:01, 123
20
26
  ```
27
+
28
+ エラー(本題)
29
+ 1行目が項目のため、型変換できないというエラーとなっている(と推察)
30
+ ```
21
- KeyError: `Records` Traceback (most recent call last): file "/var/task/sample.py", lin 35, in handler fro record in event[`Records`]
31
+ [Error] ValueError : invalid literal for int() with base 10: `ABC.csv`
22
32
  ```
23
33
 
24
34
  ### 該当のソースコード

2

ソースを一部修正・追記

2023/01/11 08:20

投稿

msy47
msy47

スコア26

test CHANGED
File without changes
test CHANGED
@@ -44,12 +44,12 @@
44
44
  IPsecTunnel = []
45
45
 
46
46
 
47
- region = '' # e.g. us-west-1
47
+ region = '(略)' # e.g. us-west-1
48
48
  service = 'es'
49
49
  credentials = boto3.Session().get_credentials()
50
50
  awsauth = AWS4Auth(credentials.access_key, credentials.secret_key, region, service, session_token=credentials.token)
51
51
 
52
- host = '' # the OpenSearch Service domain, e.g. https://search-mydomain.us-west-1.es.amazonaws.com
52
+ host = '(略)' # the OpenSearch Service domain, e.g. https://search-mydomain.us-west-1.es.amazonaws.com
53
53
  index = 'lambda-s3-index'
54
54
  type = '_doc'
55
55
  url = host + '/' + index + '/' + type

1

試したことを追記

2022/12/26 05:05

投稿

msy47
msy47

スコア26

test CHANGED
File without changes
test CHANGED
@@ -108,6 +108,8 @@
108
108
  いれて、確認したが、いずれの箇所も同様のメッセージとなり実行を
109
109
  確認することができなかった。
110
110
 
111
+ header = next(reader)
112
+
111
113
  ### 補足情報(FW/ツールのバージョンなど)
112
114
 
113
115
  Python3.8