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

refactor:レビュー指摘対応

Browse Source
This commit is contained in:
y-ono-r 2022-07-08 11:32:18 +09:00
parent b64090f06b
commit d212a101c5
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ecs/dataimport/dataimport/main.py
View File

@ -1,5 +1,4 @@
from datetime import datetime from datetime import datetime
from pickle import FALSE
import boto3 import boto3
import pymysql import pymysql
from pymysql.constants import CLIENT from pymysql.constants import CLIENT
@ -87,6 +86,7 @@ def main(bucket_name, target_data_source, target_file_name, settings_key, db_inf
cur.execute(f'SET time_zone = "+9:00"') cur.execute(f'SET time_zone = "+9:00"')
print(f'{datetime.now():%Y-%m-%d %H:%M:%S} {log_info} {LOG_LEVEL["i"]} I-MAIN-03 - タイムゾーンを変更しました') print(f'{datetime.now():%Y-%m-%d %H:%M:%S} {log_info} {LOG_LEVEL["i"]} I-MAIN-03 - タイムゾーンを変更しました')
# ④ 個別設定ファイルのロードスキーマのテーブル名に記載されているテーブルをTRUNCATEする
# 個別設定ファイルの読み込み # 個別設定ファイルの読み込み
settings_obj = s3_resource.Object(bucket_name, settings_key) settings_obj = s3_resource.Object(bucket_name, settings_key)
settings_response = settings_obj.get() settings_response = settings_obj.get()