def query_vpc_endpoint()

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


def query_vpc_endpoint(context, region_id):
    client = AcsClient(
        AK,
        SK,
        'region_id',
    )

    vpc_center_endpoint = "vpc.aliyuncs.com"
    request = CommonRequest()
    request.set_domain('vpc.aliyuncs.com')
    request.set_version('2016-04-28')
    request.set_action_name('DescribeRegions')
    request.set_method('GET')

    response = client.do_action_with_exception(request)
    res = str(response, encoding='utf-8')
    json_res = json.loads(res)
    for region_info in json_res["Regions"]["Region"]:
        if region_id == region_info["RegionId"]:
            return region_info["RegionEndpoint"]
    return vpc_center_endpoint