AWS CodePipeline Executor Python

aws-codepipeline-executor.py

import json, os
import boto3
from botocore.exceptions import ClientError

def lambda_handler(event, context):
  
    """ 
    Lambda Handler
    Triggers AWS CodePipeline
    :param event: takes event triggered by cloudwatch rule
    """
    
    client = boto3.client('codepipeline')
    
    # pipeline from lambda env
    pipeline = os.environ['CODE_PIPELINE']
    
    try: 
        response = client.start_pipeline_execution(
          name = pipeline
        )
        
        return {
            'statusCode': 200,
            'body': json.dumps(f'Pipeline executed successfully with message {response}')
        }
      
    except ClientError as e:
        raise Exception(f'Pipeline executed with error {e}')