[Lambda Python] S3のcsvをストリームで読み込みjson変換して転送したいがNo module namedエラーが発生する

Question

前提

S3にアップロードされたcsvを読み込み
json変換して、転送を試みております。

S3からcsvを読み込む際にエラーが発生しております。

エラーの解消方法についてご支援いただけると幸いです。

または別途、最善と思われる読み取り方法がありましたら
ご支援、ご教授いただけると幸いです。

参考としてるsample.py
「Lambda デプロイパッケージを作成する」
Amazon OpenSearch Service へのストリーミングデータをロードする - Amazon OpenSearch Service
https://docs.aws.amazon.com/ja_jp/opensearch-service/latest/developerguide/integrations.html#integrations-s3-lambda

実現したいこと

• S3にアップロードされたcsvを読み込む
• 読み込んだcsvをjsonへ変換する
• 変換したデータを転送する

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

[ERROR] Runtime.ImportModuleError: Unable to import module `sample` : No module named `BytesIO`
Traceback (most recent call last):

該当のソースコード

import boto3
import re
import requests
import csv
import io
import BytesIO
from requests_aws4auth import AWS4Auth

#配列
vmanagename = []
ip = []
hostname = []
session1 = []
session2 = []
sessionmax = []


region = '' # e.g. us-west-1
service = 'es'
credentials = boto3.Session().get_credentials()
awsauth = AWS4Auth(credentials.access_key, credentials.secret_key, region, service, session_token=credentials.token)

host = '' # the OpenSearch Service domain, e.g. https://search-mydomain.us-west-1.es.amazonaws.com
index = 'lambda-s3-index'
type = '_doc'
url = host + '/' + index + '/' + type

headers = { "Content-Type": "application/json" }

s3 = boto3.client('s3')

# Lambda execution starts here
def handler(event, context):
    for record in event['Records']:

        # Get the bucket name and key for the new file
        bucket = record['s3']['bucket']['name']
        key = record['s3']['object']['key']

        # Get, read, and split the file into lines
        obj = s3.get_object(Bucket=bucket, Key=key)
        body = obj['Body'].read()
        textIo = io.TextIOWrapper(io.BytesIO(body))

        # Match the regular expressions to each line and index the JSON
        for row in lines csv.reader(textIo):
            print(row)
            vmanagename = row[0]
            ip = row[1]
            hostname = row[2]
            session1 = row[3]
            session2 = row[4]
            sessionmax = row[5]

            document = { "vmanagename ": vmanagename , "ip  ": ip , "hostname ": hostname , "session1 ": session1 , "session2": session2, "sessionmax ": sessionmax }
            r = requests.post(url, auth=awsauth, json=document, headers=headers)

試したこと

No module named BytesIOをそのままの意味として受け取り
足りないモジュールは再度インストール＋デプロイしようと試みましたが
そもそもBytesIOはPythonのデフォルトに備わっており、
インストール＋デプロイも実行できず。

以下の受け取る箇所を
vmanagename = row[0]
以下のようにする必要があると考えましたが、それ以前のエラーのため確認できておりません。
vmanagename.append(str(row[0])

補足情報（FW/ツールのバージョンなど）

PythonはLambda側に準拠し3.9となります。

Comments

[msy47]

can110さん
回答ありがとうございます！
「No module named `BytesIO`」エラーは解消することができました。
別途エラーが発生しましたが、解決できない場合は別途起票致します。

Answer 1

BytesIOはioモジュールに含まれているのでimport BytesIOは不要（誤り）です。