[Lambda Python] S3のcsvをjson変換転送時(requests.post)に配列の文字列を正常に整数変換(list(map(int)できない問題

Question

前提

S3にアップロードされたcsvをストリームで読み込み
配列へ格納し、Opensearchへjson変換、一部の文字列を整数変換し
postをつかって転送する
Opensearch側でグラフ化を想定しているため、一部の文字列を整数へ変換する必要があります。

実現したいこと

• csvで取り込んだ再json変換転送時に一部の文字列整数変換したい

発生している問題

Jsonを受け取ったOpensearch側でのGET結果
整数変換転送すると2桁以上で正常に変換できない

"_index" : "lamda-s3-index",
"_type" : "_doc",
"_id" : "xxxxxx",
"_score" : 1.0,
"_source" * {
 "vmanagename" : "vnamaenamexxxx"
 "hostname" : "hostnamexxxxx"
 "devicemodel" : "devicemodelxxxxx"
 "session1" : [
  1,
  0
 ],
 "session2 : [
 9
 ],
 "sessionmax" : [
 9,
 9,
 9
 ]

文字列転送の場合

 "session1" : "10",
 "session2 : "9",
 "sessionmax" : "999"

該当のソースコード

csvサンプル
vmanagename, 1.1.1.1, hostname, devicemodel, 10, 9, 999

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

#配列
vmanagename = []
ip = []
hostname = []
devicemodel = []
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]
            devicemodel = row[2]
            hostname = row[3]
            session1 = row[4]
            session2 = row[5]
            sessionmax = row[6]
            print(row[0], row[1], row[2], row[3], row[4], row[5], row[6])

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

試したこと

ストリームで取り込んだ文字列を整数変換しようと調べた結果
mapを使用すると変換できるとのことだったので使用してみましたが
正常に整数に変換することができず。
list(map(int, session2)

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

Python3.9

Comments

[msy47]

qnoirさん
ご指摘ありがとうございます！
想定どおりの整数で転送することができました！
ありがとうございます。

Answer 1

 "sessionmax" : [
 9,
 9,
 9
 ]

のようになってしまう理由は、「999」というシーケンスに対して map を適用しているからだと思われます。

普通にintで囲むだけではだめなのでしょうか。

document = { "vmanagename ": vmanagename , 
  "ip  ": ip , 
  "devicemodel ": devicemodel , 
  "hostname ": hostname , 
  "session1 ": [int(session1)] ,
  "session2": [int(session2)], 
  "sessionmax ": [int(sessionmax)] }

Comments

[msy47]

qnoirさん
ご指摘ありがとうございます！
想定どおりの整数で転送することができました！
ありがとうございます。