"""Config file for set-track-performers lambda.""" from logging import INFO import os import uuid from graphql_backoff import GraphQLBackoffConnector from owslogger import logger # Bulk Ingestion Source ID is always 1001. CATALOG_INGESTION_SOURCE_ID=1001 DEV_ENVIRONMENT = 'dev' ENVIRONMENT = os.environ.get('Environment', DEV_ENVIRONMENT) # Processing info BUCKET = os.environ.get('BUCKET') KEY = os.environ.get('KEY') VENDOR_ID = int(os.environ.get('VENDOR_ID')) SUBACCOUNT_ID = int(os.environ.get('SUBACCOUNT_ID') or 0) APPLICATION_NAME = 'bulk-metadata-ingester' LAMBDA_NAME = f'{APPLICATION_NAME}-set-track-performers' # GraphQL GRAPHQL_GATEWAY_URL = os.environ.get('GRAPHQL_GATEWAY_URL') OA_USER = os.environ.get('OA_USER') LOGGING_LEVEL = os.environ.get('LOGGING_LEVEL', INFO) graphql_gateway = GraphQLBackoffConnector(GRAPHQL_GATEWAY_URL, LAMBDA_NAME) DEV_CORRELATION_ID = os.environ.get('DEV_CORRELATION_ID') or uuid.uuid4() app_logger = logger.setup( environment=ENVIRONMENT, logger_name=LAMBDA_NAME, logger_level=LOGGING_LEVEL, service_name=LAMBDA_NAME, service_version='1.0.0', correlation_id=DEV_CORRELATION_ID ) 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 DEV_CORRELATION_ID})