"""Config file for parse-sme-marketing lambda.""" from logging import INFO import os import uuid from lambdacommon import util from owslogger import logger from secrets_manager.lambda_ext import LambdaSecretsManager DEV_ENVIRONMENT = 'dev' ENVIRONMENT = os.environ.get('Environment', DEV_ENVIRONMENT) LAMBDA_NAME = 'lambda-bulk-assets-ingester-pre-process-audio' APPLICATION_NAME = 'bulk-assets-ingester' LOGGING_LEVEL = os.environ.get('LOGGING_LEVEL', INFO) LOGGER_DSN = os.environ.get('LOGGER_DSN') app_logger = util.setup_ows_logger( ENVIRONMENT, LAMBDA_NAME, LOGGING_LEVEL, APPLICATION_NAME, '1.0.0') secrets_manager_client = LambdaSecretsManager( environment=ENVIRONMENT, service_name=LAMBDA_NAME) STAGING_S3_BUCKET = os.environ.get('STAGING_S3_BUCKET') SNOWFLAKE_S3_BUCKET = os.environ.get('SNOWFLAKE_S3_BUCKET') SNOWFLAKE_S3_LOCATION = os.environ.get('SNOWFLAKE_S3_LOCATION') CATALOG_INGESTION_SOURCE_ID = str(os.environ.get( 'CATALOG_INGESTION_SOURCE_ID', 1001)) util.init_sentry_for_lambda() 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()})