def parse_flowlog_tag()

in code/ct_flowlog_activator.py [0:0]


def parse_flowlog_tag(tags, resource_type):
    '''
    Search for tags with key 'flowlog'.
    If no tags found on VPC, default to ALL traffic.
    If no tags found on Subnet, do nothing
    '''
    try:
        if resource_type == "VPC": 
            flowlog_tag = get_flowlog_filter(os.environ['default_traffic_to_log'])
        else: 
            flowlog_tag = -1
        
        if tags:
            for key, value in tags.items():
                if str.lower(key) in tag_keyword:
                    if str.lower(value) in str(os.environ['tag_all_values']).replace(" ", "").split(","):
                        flowlog_tag = 3
                    elif str.lower(value) in str(os.environ['tag_accept_values']).replace(" ", "").split(","):
                        flowlog_tag = 2
                    elif str.lower(value) in str(os.environ['tag_reject_values']).replace(" ", "").split(","):
                        flowlog_tag = 1
                    else:
                        flowlog_tag = 0
                    LOGGER.info("Found tag : {} = {}".format(key, value))
                    break

        return flowlog_tag
    except Exception as e:
        LOGGER.error("Failed to search Flow Log tag: {}".format(e), exc_info=True)