def disk_exists_v2()

in src/ansible_collections/alibaba/apsarastack/plugins/modules/ali_ecs_tag.py [0:0]


def disk_exists_v2(module, conn):
    try:
        disk_list = []
        i = 1
        params = {
            "PageNumber": i,
            "PageSize": 10,
        }
        response = do_common_request(
            conn, "POST", "Ecs", "2014-05-26", "DescribeDisks", body=params)
        for disk in response["Disks"]["Disk"]:
            if disk["DiskId"] in module.params['resource_ids']:
                disk_list.append(disk)
        while response["Disks"]["Disk"] and (i-1) * params["PageSize"] + len(response["Disks"]["Disk"]) < response["TotalCount"]:
            i += 1
            params = {
                "PageNumber": i,
                "PageSize": 10,
            }
            response = do_common_request(
            conn, "POST", "Ecs", "2014-05-26", "DescribeDisks", body=params)
            for disk in response["Disks"]["Disk"]:
                if disk["DiskId"] in module.params['resource_ids']:
                    disk_list.append(disk)
    except Exception as e:
        module.fail_json(msg="Failed to disk_exists_v2: {0}".format(e))
    else:
        return disk_list