"""Config file for handle-artwork lambda.""" from logging import INFO import os import uuid from lambdacommon import util from lambdacommon.graphql.graphql import GraphQLConnector 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-handle-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 ) GRAPHQL_GATEWAY_URL = os.environ.get('GRAPHQL_GATEWAY_URL') OA_USER = os.environ.get('OA_USER') graphql_gateway = GraphQLConnector(GRAPHQL_GATEWAY_URL, APPLICATION_NAME) SNOWFLAKE_S3_BUCKET = os.environ.get( 'SNOWFLAKE_S3_BUCKET', 'qa-bulk-assets-ingester') SNOWFLAKE_S3_LOCATION = os.environ.get('SNOWFLAKE_S3_LOCATION', 'snowflake') CATALOG_INGESTION_SOURCE_ID = str(os.environ.get( 'CATALOG_INGESTION_SOURCE_ID', 1001)) # 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()})