66 lines
4.6 KiB
Python
66 lines
4.6 KiB
Python
import os
|
|
|
|
import src.system_var.constants as constants
|
|
|
|
# environments(task settings file)
|
|
# ログ出力レベル。DEBUG, INFO, WARNING, ERRORの4つから指定する
|
|
LOG_LEVEL = os.environ.get(constants.LOG_LEVEL, constants.LOG_LEVEL_INFO)
|
|
# CRMへの認証処理のタイムアウト秒数
|
|
CRM_AUTH_TIMEOUT = float(os.environ.get(constants.CRM_AUTH_TIMEOUT, 100))
|
|
# CRMのレコード件数取得処理のタイムアウト秒数
|
|
CRM_GET_RECORD_COUNT_TIMEOUT = float(os.environ.get(constants.CRM_GET_RECORD_COUNT_TIMEOUT, 300))
|
|
# CRMのレコード件数取得処理の最大リトライ試行回数(処理の実施総回数)
|
|
CRM_GET_RECORD_COUNT_MAX_RETRY_ATTEMPT = int(os.environ.get(constants.CRM_GET_RECORD_COUNT_MAX_RETRY_ATTEMPT, 4))
|
|
# CRMのレコード件数取得処理のリトライ時の初回待ち秒数
|
|
CRM_GET_RECORD_COUNT_RETRY_INTERVAL = int(os.environ.get(constants.CRM_GET_RECORD_COUNT_RETRY_INTERVAL, 5))
|
|
# CRMのレコード件数取得処理のリトライ時の最小待ち秒数
|
|
CRM_GET_RECORD_COUNT_RETRY_MIN_INTERVAL = int(os.environ.get(constants.CRM_GET_RECORD_COUNT_RETRY_MIN_INTERVAL, 5))
|
|
# CRMのレコード件数取得処理のリトライ時の最大待ち秒数
|
|
CRM_GET_RECORD_COUNT_RETRY_MAX_INTERVAL = int(os.environ.get(constants.CRM_GET_RECORD_COUNT_RETRY_MAX_INTERVAL, 50))
|
|
# CRMのレコード取得処理のタイムアウト秒数
|
|
CRM_FETCH_RECORD_TIMEOUT = float(os.environ.get(constants.CRM_FETCH_RECORD_TIMEOUT, 300))
|
|
# CRMのレコード取得処理の最大リトライ試行回数(処理の実施総回数)
|
|
CRM_FETCH_RECORD_MAX_RETRY_ATTEMPT = int(os.environ.get(constants.CRM_FETCH_RECORD_MAX_RETRY_ATTEMPT, 4))
|
|
# CRMのレコード取得処理のリトライ時の初回待ち秒数
|
|
CRM_FETCH_RECORD_RETRY_INTERVAL = int(os.environ.get(constants.CRM_FETCH_RECORD_RETRY_INTERVAL, 5))
|
|
# CRMのレコード取得処理のリトライ時の最小待ち秒数
|
|
CRM_FETCH_RECORD_RETRY_MIN_INTERVAL = int(os.environ.get(constants.CRM_FETCH_RECORD_RETRY_MIN_INTERVAL, 5))
|
|
# CRMのレコード取得処理のリトライ時の最大待ち秒数
|
|
CRM_FETCH_RECORD_RETRY_MAX_INTERVAL = int(os.environ.get(constants.CRM_FETCH_RECORD_RETRY_MAX_INTERVAL, 50))
|
|
# CRMデータの日時を変換するときのタイムゾーン
|
|
CONVERT_TZ = os.environ.get(constants.CONVERT_TZ, 'Asia/Tokyo')
|
|
# CRM取得対象オブジェクトの情報のファイル名
|
|
OBJECT_INFO_FILENAME = os.environ[constants.OBJECT_INFO_FILENAME]
|
|
|
|
# environments(ECS Task Environment)
|
|
# CRMのAPI実行のための認証エンドポイントのドメイン
|
|
CRM_AUTH_DOMAIN = os.environ[constants.CRM_AUTH_DOMAIN]
|
|
# CRMのAPI実行用ユーザ名
|
|
CRM_USER_NAME = os.environ[constants.CRM_USER_NAME]
|
|
# CRMのAPI実行用ユーザパスワード
|
|
CRM_USER_PASSWORD = os.environ[constants.CRM_USER_PASSWORD]
|
|
# CRMのAPI実行用ユーザのセキュリティトークン
|
|
CRM_USER_SECURITY_TOKEN = os.environ[constants.CRM_USER_SECURITY_TOKEN]
|
|
# CRMデータ取得用の設定ファイルを格納するバケット名
|
|
CRM_CONFIG_BUCKET = os.environ[constants.CRM_CONFIG_BUCKET]
|
|
# CRMのバックアップデータを格納するバケット名
|
|
CRM_BACKUP_BUCKET = os.environ[constants.CRM_BACKUP_BUCKET]
|
|
# CRMの取込データを格納するバケット名
|
|
IMPORT_DATA_BUCKET = os.environ[constants.IMPORT_DATA_BUCKET]
|
|
# CRM取得対象オブジェクトの情報を格納するフォルダパス
|
|
OBJECT_INFO_FOLDER = os.environ.get(constants.OBJECT_INFO_FOLDER, 'crm/object_info')
|
|
# CRMデータ取得結果を格納するフォルダパス
|
|
PROCESS_RESULT_FOLDER = os.environ.get(constants.PROCESS_RESULT_FOLDER, 'data_import')
|
|
# CRMデータ取得結果を格納するファイル名
|
|
PROCESS_RESULT_FILENAME = os.environ.get(constants.PROCESS_RESULT_FILENAME, 'process_result.json')
|
|
# CRMからの最終取得日時ファイルを格納するフォルダパス
|
|
LAST_FETCH_DATE_FOLDER = os.environ.get(constants.LAST_FETCH_DATE_FOLDER, 'crm/last_fetch_datetime')
|
|
# CRMから取得し、取込用に変換したデータを格納するフォルダ
|
|
CRM_IMPORT_DATA_FOLDER = os.environ.get(constants.CRM_IMPORT_DATA_FOLDER, 'crm/target')
|
|
# CRMから取得した生データのバックアップを格納するフォルダパス
|
|
RESPONSE_JSON_BACKUP_FOLDER = os.environ.get(constants.RESPONSE_JSON_BACKUP_FOLDER, 'response_json')
|
|
# CRMから取得し、取込用に変換したデータのバックアップを格納するフォルダ
|
|
CRM_IMPORT_DATA_BACKUP_FOLDER = os.environ.get(constants.CRM_IMPORT_DATA_BACKUP_FOLDER, 'data_import')
|
|
# 一気通貫テスト用、取得件数を絞るためのSOQL句
|
|
FETCH_LIMIT_CLAUSE = os.environ.get('FETCH_LIMIT_CLAUSE', '')
|