Cloudfront cache invalidation lambda

index.py

import boto3
import os

code_pipeline = boto3.client("codepipeline")
cloud_front = boto3.client("cloudfront")

def lambda_handler(event, context):
    print(event)
    job_id = event["CodePipeline.job"]["id"]
    try:
        print("distribution id : "+os.environ.get("CLOUDFRONT_DISTRIBUTION_ID"))
        cloud_front.create_invalidation(
            DistributionId=os.environ.get("CLOUDFRONT_DISTRIBUTION_ID"),
            InvalidationBatch={
                "Paths": {
                    "Quantity": 1,
                    "Items": ["/*"],
                },
                "CallerReference": event["CodePipeline.job"]["id"],
            },
        )
    except Exception as e:
        print("error: "+str(e))
        code_pipeline.put_job_failure_result(
            jobId=job_id,
            failureDetails={
                "type": "JobFailed",
                "message": str(e),
            },
        )
    else:
        code_pipeline.put_job_success_result(
            jobId=job_id,
        )