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

style: フォーマットが適用されたのを修正

Browse Source 
本当は直したいけど影響があるといけないのでもとに戻す
This commit is contained in:
shimoda.m@nds-tyo.co.jp 2022-07-02 16:51:07 +09:00
parent 3ca1a8d7b6
commit b33a3dae19
1 changed files with 8 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
lambda/sap-data-decrypt/datadecrypt/main.py
View File

@ -1,12 +1,12 @@
import datetime
import logging import logging
import os import os
import traceback
from abc import *
from zoneinfo import ZoneInfo
import boto3 import boto3
import gnupg import gnupg
import datetime
import logging
from abc import *
from zoneinfo import ZoneInfo
import traceback
# 環境変数 # 環境変数
SECRET_KEY_FILE_BUCKET_NAME = os.environ["SECRET_KEY_FILE_BUCKET_NAME"] SECRET_KEY_FILE_BUCKET_NAME = os.environ["SECRET_KEY_FILE_BUCKET_NAME"]
@ -42,12 +42,8 @@ sns_client = boto3.client('sns')
# logger設定 # logger設定
logger = logging.getLogger() logger = logging.getLogger()
def custome_time(*arg): def custome_time(*arg):
return datetime.datetime.now(ZoneInfo("Asia/Tokyo")).timetuple() return datetime.datetime.now(ZoneInfo("Asia/Tokyo")).timetuple()
formatter = logging.Formatter( formatter = logging.Formatter(
'[%(levelname)s]\t%(asctime)s\t%(message)s\n', '[%(levelname)s]\t%(asctime)s\t%(message)s\n',
'%Y-%m-%d %H:%M:%S' '%Y-%m-%d %H:%M:%S'
@ -140,8 +136,7 @@ def handler(event, context):
'Key': s3_event.file_path 'Key': s3_event.file_path
} }
backup_file_key = f'{s3_event.data_source_name}/{execute_date}/{s3_event.file_name}' backup_file_key = f'{s3_event.data_source_name}/{execute_date}/{s3_event.file_name}'
logger.info( logger.info(f'I-07-04 PGP暗号化ファイル移動　移動元：{s3_event.bucket_name}/{s3_event.file_path}　移動先：{SAP_DATA_BACKUP_BUCKET_NAME}/{backup_file_key}')
f'I-07-04 PGP暗号化ファイル移動　移動元：{s3_event.bucket_name}/{s3_event.file_path}　移動先：{SAP_DATA_BACKUP_BUCKET_NAME}/{backup_file_key}')
backup_file_obj = s3_resource.Object(SAP_DATA_BACKUP_BUCKET_NAME, backup_file_key) backup_file_obj = s3_resource.Object(SAP_DATA_BACKUP_BUCKET_NAME, backup_file_key)
backup_file_obj.copy(copy_source) backup_file_obj.copy(copy_source)
s3_client.delete_object(Bucket=s3_event.bucket_name, Key=s3_event.file_path) s3_client.delete_object(Bucket=s3_event.bucket_name, Key=s3_event.file_path)
@ -177,8 +172,7 @@ def create_status_file(s3_event, extension) -> None:
result_error_key = s3_event.data_source_name + DIRECTORY_RECV + result_error_file_name result_error_key = s3_event.data_source_name + DIRECTORY_RECV + result_error_file_name
result_error_obj = s3_resource.Object(s3_event.bucket_name, result_error_key) result_error_obj = s3_resource.Object(s3_event.bucket_name, result_error_key)
result_error_obj.put(Body='') result_error_obj.put(Body='')
logger.error( logger.error(f'E-ERR-01 recvディレクトリにエラーファイルを作成しました　ファイル名：{result_error_file_name}　出力先：{s3_event.bucket_name}/{result_error_key}')
f'E-ERR-01 recvディレクトリにエラーファイルを作成しました　ファイル名：{result_error_file_name}　出力先：{s3_event.bucket_name}/{result_error_key}')
except Exception as e: except Exception as e:
logger.error(f'E-96 エラーステータスファイルの作成に失敗しました　エラー内容：{e}') logger.error(f'E-96 エラーステータスファイルの作成に失敗しました　エラー内容：{e}')
traceback.print_exc() traceback.print_exc()
@ -197,8 +191,7 @@ def move_encrypt_file(s3_event) -> None:
error_obj = s3_resource.Object(s3_event.bucket_name, error_key) error_obj = s3_resource.Object(s3_event.bucket_name, error_key)
error_obj.copy(copy_source) error_obj.copy(copy_source)
s3_client.delete_object(Bucket=s3_event.bucket_name, Key=s3_event.file_path) s3_client.delete_object(Bucket=s3_event.bucket_name, Key=s3_event.file_path)
logger.error( logger.error(f'E-ERR-02 recv_errorディレクトリにファイルを移動しました　移動元：{s3_event.bucket_name}/{s3_event.file_path}　移動先：{s3_event.bucket_name}/{error_key}')
f'E-ERR-02 recv_errorディレクトリにファイルを移動しました　移動元：{s3_event.bucket_name}/{s3_event.file_path}　移動先：{s3_event.bucket_name}/{error_key}')
except Exception as e: except Exception as e:
logger.error(f'E-97 PGP暗号化ファイルの移動に失敗しました　エラー内容：{e}') logger.error(f'E-97 PGP暗号化ファイルの移動に失敗しました　エラー内容：{e}')
traceback.print_exc() traceback.print_exc()