"""Config file for trigger-state-machine lambda.""" from logging import INFO import os import uuid from lambdacommon import util from owslogger import logger from secrets_manager.lambda_ext import LambdaSecretsManager util.init_sentry_for_lambda() DEV_ENVIRONMENT = 'dev' ENVIRONMENT = os.environ.get('Environment', DEV_ENVIRONMENT) LAMBDA_NAME = 'lambda-bulk-assets-ingester-trigger-sfn' APPLICATION_NAME = 'bulk-assets-ingester' secrets_manager_client = LambdaSecretsManager( environment=ENVIRONMENT, service_name=LAMBDA_NAME) LOGGING_LEVEL = os.environ.get('LOGGING_LEVEL', INFO) LOGGER_DSN = os.environ.get('LOGGER_DSN') BULK_ASSETS_STATE_MACHINE_ARN = os.environ.get('BULK_ASSETS_STATE_MACHINE_ARN') app_logger = util.setup_ows_logger( ENVIRONMENT, LAMBDA_NAME, LOGGING_LEVEL, APPLICATION_NAME, '1.0.0') # DDEX_INGESTER_INTEGRATION: replaced lamda-ddex-common logger with ad-hoc # logger def get_current_logger(correlation_id=None): """Get logger with a correlation_id attached. Args: correlation_id: correlation_id that will be sent along with log record Returns: logger.OwsLoggingAdapter: instance of OwsLoggingAdapter with correlation_id attached. """ return logger.OwsLoggingAdapter( app_logger, {'correlation_id': correlation_id or uuid.uuid4()})