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

fix: ファイル名の日付フォーマットを修正

Browse Source
This commit is contained in:
Y_SAKAI 2022-08-02 09:55:30 +09:00
parent 96487ccb25
commit 75187e54e9
2 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
ecs/crm-datafetch/src/config/objects.py
View File

@ -15,6 +15,7 @@ from src.system_var.constants import (COLUMNS_KEY, COLUMNS_TYPE,
UPLOAD_FILE_NAME_KEY,
UPLOAD_FILE_NAME_TYPE)
from src.util.dict_checker import DictChecker
from src.util.execute_datetime import ExecuteDateTime
class FetchTargetObjects():
@ -40,7 +41,7 @@ class FetchTargetObjects():
class TargetObject():
def __init__(self, object_info, execute_datetime) -> None:
def __init__(self, object_info, execute_datetime: ExecuteDateTime) -> None:
self.__dict_checker = DictChecker(object_info)
self.__object_info = object_info
self.__execute_datetime = execute_datetime
@ -105,8 +106,8 @@ class TargetObject():
@property
def upload_file_name(self) -> str:
if self.__dict_checker.check_key_exist(UPLOAD_FILE_NAME_KEY):
return self.__object_info[UPLOAD_FILE_NAME_KEY].format(execute_datetime=self.__execute_datetime)
return f'{self.__object_info[OBJECT_NAME_KEY]}_{self.__execute_datetime}'
return self.__object_info[UPLOAD_FILE_NAME_KEY].format(execute_datetime=self.__execute_datetime.to_YYYYMMDDHHMMSS)
return f'{self.__object_info[OBJECT_NAME_KEY]}_{self.__execute_datetime.to_YYYYMMDDHHMMSS}'
@property
def datetime_column(self) -> str:

3
ecs/crm-datafetch/src/util/execute_datetime.py
View File

@ -12,3 +12,6 @@ class ExecuteDateTime:
def to_path(self) -> str:
return self.__execute_datetime.rstrip(MILLISEC_FORMAT).translate(str.maketrans({'-': '/', 'T': '/', ':': None, '.': None}))
def to_YYYYMMDDHHMMSS(self) -> str:
return self.__execute_datetime.rstrip(MILLISEC_FORMAT).translate(str.maketrans({'-': None, 'T': None, ':': None, '.': None}))