feat:下田さんのレビュー指摘修正
This commit is contained in:
parent
23727bdf45
commit
3a177ae18c
@ -5,8 +5,7 @@ import csv
|
||||
import sys
|
||||
from end import end
|
||||
from error import error
|
||||
from common import debug_log
|
||||
from common import convert_quotechar
|
||||
from common import debug_log, convert_quotechar
|
||||
|
||||
# 定数
|
||||
DIRECTORY_WORK = '/work/'
|
||||
@ -83,12 +82,13 @@ def check(bucket_name, target_data_source, target_file_name, settings_key, log_i
|
||||
work_obj = s3_resource.Object(bucket_name, work_key)
|
||||
work_response = work_obj.get()
|
||||
work_data = io.TextIOWrapper(io.BytesIO(work_response["Body"].read()), encoding=settings_list[SETTINGS_ITEM["charCode"]], newline=LINE_FEED_CODE[settings_list[SETTINGS_ITEM["lineFeedCode"]]])
|
||||
work_header_list = []
|
||||
work_header_list = []
|
||||
# ヘッダ行のみのファイルは、0バイトファイル同等とみなす
|
||||
for i, line in enumerate(csv.reader(work_data, quotechar=convert_quotechar(settings_list[SETTINGS_ITEM["quotechar"]]), delimiter=settings_list[SETTINGS_ITEM["delimiter"]])):
|
||||
if int(settings_list[SETTINGS_ITEM["headerFlag"]]) == True and i == 0:
|
||||
work_header_list = line
|
||||
continue
|
||||
|
||||
|
||||
break
|
||||
|
||||
# ② C-0のデータ件数チェックを開始する
|
||||
|
||||
@ -1,6 +1,5 @@
|
||||
from datetime import datetime
|
||||
|
||||
|
||||
# 定数
|
||||
LOG_LEVEL = {"d": 'Debug'}
|
||||
MODE_TYPE = {
|
||||
|
||||
@ -6,8 +6,7 @@ from pymysql.constants import CLIENT
|
||||
import io
|
||||
import csv
|
||||
from error import error
|
||||
from common import debug_log
|
||||
from common import convert_quotechar
|
||||
from common import debug_log, convert_quotechar
|
||||
|
||||
# 定数
|
||||
DIRECTORY_WORK = '/work/'
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user