def delete_flowlog()

in code/ct_flowlog_activator.py [0:0]

• 29 lines of code
• 5 McCabe index (conditional complexity)

def delete_flowlog(target_session, accountId, resourceId, region):
    '''
    Delete the existing vpc flow log, only removes flow log with destination set to S3
    '''
    try:
        ec2_client = target_session.client('ec2', region_name=region)
        flowlogs = ec2_client.describe_flow_logs(
            Filter=[
                {
                    'Name': 'resource-id',
                    'Values': [
                        resourceId,
                    ]
                },
            ],
        )

        flowlog_ids = []
        for flowlog in flowlogs['FlowLogs']:
            if flowlog['LogDestinationType'] == 's3':
                flowlog_ids.append(flowlog['FlowLogId'])

        response = ec2_client.delete_flow_logs(
            FlowLogIds=flowlog_ids
        )
        if len(response['Unsuccessful']) > 0:
            LOGGER.error("Delete Flow Log Unsuccessful: {}".format(response))
        else:
            return response

    except Exception as e:
        LOGGER.error("Could not delete Flow Log : {}".format(e), exc_info=True)