Function lambda_handler

src/sync_cache_settings_function/main.py:305–330

(event, _)

@logger.inject_lambda_context
@tracer.capture_lambda_handler
def lambda_handler(event, _):
    # The "event" is the configuration (passed as input to step function)
    logger.info(event)

    # Check the autoProvision flag on all cacheControl objects to make sure auto-provisioning is not disabled.
    jsonpath_expr = parse('$..cacheControl[*].autoProvision')
    auto_provision = [match.value for match in jsonpath_expr.find(event)]
    logger.debug('cacheControl.autoProvision values: %s', auto_provision)
    if len(auto_provision) == 0 or not False in auto_provision:
        origin_request_headers, cache_headers = determine_required_cloudfront_headers(event)

        if REST_API_ID and REST_API_STAGE:
            update_apigw_rest_stage_caching(event, cache_headers)
            pass
        else:
            # This can be the case when a dedicated CloudFront distribution is being used for caching.
            logger.info('REST API ID and/or stage name are not specified; skipping REST API sync')

        if CLOUD_FRONT_CACHE_POLICY_ID and CLOUD_FRONT_ORIGIN_REQUEST_POLICY_ID:
            update_cloudfront_origin_request_policy(origin_request_headers)
            update_cloudfront_cache_policy(event, cache_headers)
        else:
            # This can be the case when an API Gateway Edge endpoint type is being used (API Gateway manages its own CloudFront distribution)
            logger.info('CloudFront cache policy ID and/or origin request policy ID are not specified; skipping')
    else:
        logger.info('Auto provisioning of caching related resources is disabled for at least one cacheControl configuration; skipping CloudFront/API Gateway sync')