def handler()

in functions/source/TerminateandReSwap/index.py [0:0]

• 39 lines of code
• 7 McCabe index (conditional complexity)

def handler(event, context):
    # make sure we send a failure to CodePipeline if the function is going to timeout
    timer = threading.Timer((context.get_remaining_time_in_millis() / 1000.00) - 0.5, timeout, args=[event, context])
    timer.start()
    try:
        # Extract the Job ID
        job_id = event['CodePipeline.job']['id']
        # Extract the Job Data
        job_data = event['CodePipeline.job']['data']
        user_parameters = job_data['actionConfiguration']['configuration']['UserParameters']
        #Calling DeleteConfigTemplate API
        DeleteConfigTemplate=DeleteConfigTemplateBlue(AppName=(json.loads(user_parameters)['BeanstalkAppName']),TempName=(json.loads(user_parameters)['CreateConfigTempName']))
        print (DeleteConfigTemplate)
        #re-swapping the urls
        reswap = SwapGreenandBlue(SourceEnv=(json.loads(user_parameters)['BlueEnvName']),DestEnv=(json.loads(user_parameters)['GreenEnvName']))
        if reswap == "Failure":
            raise Exception("Re-Swap did not happen")
        print ("Deleting the GreenEnvironment")
        DeleteGreenEnvironment(EnvName=(json.loads(user_parameters)['GreenEnvName']))
        #Delete the S3 CNAME Config file
        s3 = boto3.resource('s3')
        bucket = s3.Bucket(json.loads(user_parameters)['BlueCNAMEConfigBucket'])
        key = 'hello.json'
        objs = list(bucket.objects.filter(Prefix=key))
        if len(objs) > 0 and objs[0].key == key:
            obj = s3.Object(json.loads(user_parameters)['BlueCNAMEConfigBucket'],json.loads(user_parameters)['BlueCNAMEConfigFile'])
            obj.delete()
            print ("Successfully deleted the CNAME Config file")
        else:
            print("Seems like the CNAME Config file is already deleted!")
        #Send Success Message to CodePipeline
        Status="Success"
        Message="Successfully reswapped and terminated the Green Environment"

    except Exception as e:
        print('Function failed due to exception.')
        e = sys.exc_info()[0]
        print(e)
        traceback.print_exc()
        Status="Failure"
        Message=("Error occured while executing this. The error is %s" %e)

    finally:
        timer.cancel()
        if (Status =="Success"):
            put_job_success(job_id, Message)
        else:
            put_job_failure(job_id, Message)