nik/newdwh2021
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix:SAPデータ日次受領チェック処理 responseをreadすると行数が取得できなくなってしまうため、オブジェクトから再取得するように修正した

Browse Source
This commit is contained in:
*lcOeIaePm0 2022-05-30 13:38:32 +09:00
parent b589223bc7
commit 6144d04382
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
lambda/mbj-newdwh2021-staging-lambda-sap-fin-receive-check-daily.py
View File

@ -126,7 +126,7 @@ def lambda_handler(event, context):
logger.info('I-04-04 取得したオブジェクトリストと日次I/Fファイルネーム設定ファイルの突き合わせを開始します') logger.info('I-04-04 取得したオブジェクトリストと日次I/Fファイルネーム設定ファイルの突き合わせを開始します')
receive_daily_file_name_body = io.TextIOWrapper(io.BytesIO(receive_daily_file_name_response["Body"].read()), encoding='utf-8') receive_daily_file_name_body = io.TextIOWrapper(io.BytesIO(receive_daily_file_name_response["Body"].read()), encoding='utf-8')
match_count = 0 match_count = 0
row_count = sum(1 for line in io.BytesIO(receive_daily_file_name_response["Body"].read())) row_count = sum(1 for line in io.BytesIO(receive_daily_file_name_obj.get()["Body"].read()))
for row in csv.reader(receive_daily_file_name_body, delimiter='\t'): for row in csv.reader(receive_daily_file_name_body, delimiter='\t'):
file_exists = False file_exists = False
for file_name in file_list: for file_name in file_list:

2
lambda/mbj-newdwh2021-staging-lambda-sap-sup-receive-check-daily.py
View File

@ -126,7 +126,7 @@ def lambda_handler(event, context):
logger.info('I-04-04 取得したオブジェクトリストと日次I/Fファイルネーム設定ファイルの突き合わせを開始します') logger.info('I-04-04 取得したオブジェクトリストと日次I/Fファイルネーム設定ファイルの突き合わせを開始します')
receive_daily_file_name_body = io.TextIOWrapper(io.BytesIO(receive_daily_file_name_response["Body"].read()), encoding='utf-8') receive_daily_file_name_body = io.TextIOWrapper(io.BytesIO(receive_daily_file_name_response["Body"].read()), encoding='utf-8')
match_count = 0 match_count = 0
row_count = sum(1 for line in io.BytesIO(receive_daily_file_name_response["Body"].read())) row_count = sum(1 for line in io.BytesIO(receive_daily_file_name_obj.get()["Body"].read()))
for row in csv.reader(receive_daily_file_name_body, delimiter='\t'): for row in csv.reader(receive_daily_file_name_body, delimiter='\t'):
file_exists = False file_exists = False
for file_name in file_list: for file_name in file_list: