def query_vpc_logs()

in rules/customer-fc/vpc_flow_logs_enabled.py [0:0]

• 19 lines of code
• 3 McCabe index (conditional complexity)

def query_vpc_logs(context, region_id, vpc_id):
    client = AcsClient(AK, SK, region_id)

    vpc_endpoint = query_vpc_endpoint(context, region_id)
    request = CommonRequest()
    request.set_protocol_type(protocol_type.HTTPS)
    request.set_domain(vpc_endpoint)
    request.set_version('2016-04-28')
    request.set_action_name('DescribeFlowLogs')
    request.set_method('GET')
    request.add_query_param('RegionId', region_id)
    request.add_query_param('ResourceType', 'VPC')
    request.add_query_param('ResourceId', vpc_id)
    request.add_query_param('Status', 'Active')

    response = client.do_action_with_exception(request)
    res = str(response, encoding='utf-8')
    json_res = json.loads(res)
    if "TotalCount" in json_res and json_res["TotalCount"] > 0:
        return json_res["TotalCount"] > 0
    return None