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)