"""Lambda module.""" from content_utils.exceptions import IneligibleEventError from content_utils.logging.logger import ContentLambdaLogger import sentry_sdk from sentry_sdk.integrations.aws_lambda import AwsLambdaIntegration from src import config from src import logic if config.SENTRY_DSN: sentry_sdk.init( dsn=config.SENTRY_DSN, environment=config.ENVIRONMENT, integrations=[AwsLambdaIntegration(timeout_warning=True)] ) lambda_logger = ContentLambdaLogger(config.app_logger) def handler(event, context=None): """Lambda Entry point.""" lambda_logger.start() lambda_logger.set_data(queue_id=event.get('review_queue_id')) lambda_logger.logger.debug(event) try: result = logic.process_event(event) lambda_logger.set_data(status='success', result=result) except IneligibleEventError as e: lambda_logger.set_data(status='skip', result=str(e)) except Exception as e: lambda_logger.set_data(status='error', result=str(e)) raise e finally: lambda_logger.end()