Huawei Cloud Storage Query

huaweicloudsdkcore>=3.1.0
huaweicloudsdkiam>=3.1.0
huaweicloudsdkevs>=3.1.0
huaweicloudsdksfsturbo>=3.1.0
huaweicloudsdkobs>=3.1.0
huaweicloudsdkcbr>=3.1.0

import argparse
import sys
import os

sys.path.insert(0, os.path.join(os.path.dirname(__file__), '..'))

from config import load_credentials, build_http_config
from huaweicloudsdkcore.auth.credentials import BasicCredentials
from huaweicloudsdkcbr.v1 import CbrClient
from huaweicloudsdkcbr.v1.model.check_agent_request import CheckAgentRequest
from huaweicloudsdkcbr.v1.model.protectable_agent_req import ProtectableAgentReq
from huaweicloudsdkcbr.v1.model.protectable_agent_status_resource import ProtectableAgentStatusResource
from huaweicloudsdkcbr.v1.region.cbr_region import CbrRegion

AK, SK, Region, SecurityToken = load_credentials()

parser = argparse.ArgumentParser(description="查询 CBR 客户端状态")
parser.add_argument("--project_id", type=str, required=True, help="项目 ID")
parser.add_argument("--region", type=str, help="区域，默认 cn-north-4")
parser.add_argument("--resource_ids", type=str, required=True, help="资源ID列表，多个以英文逗号分隔")
parser.add_argument("--resource_names", type=str, help="资源名称列表，多个以英文逗号分隔，与resource_ids一一对应")
parser.add_argument("--resource_types", type=str, required=True, help="资源类型列表，多个以英文逗号分隔，与resource_ids一一对应，取值: OS::Nova::Server, OS::Cinder::Volume, OS::Sfs::Turbo, OS::Workspace::DesktopV2")
args = parser.parse_args()

if args.region is not None:
    Region = args.region

try:
    http_config = build_http_config()

    client = CbrClient.new_builder().with_http_config(http_config).with_credentials(
        BasicCredentials(AK, SK, args.project_id) if not SecurityToken else BasicCredentials(AK, SK, args.project_id).with_security_token(SecurityToken)).with_region(CbrRegion.value_of(Region)).build()
    if not client:
        print(f"无法获取 CBR 客户端")
        exit(-1)

    resource_ids = [rid.strip() for rid in args.resource_ids.split(',') if rid.strip()]
    resource_names = [n.strip() for n in args.resource_names.split(',') if n.strip()] if args.resource_names else []
    resource_types = [t.strip() for t in args.resource_types.split(',') if t.strip()]

    if len(resource_types) != len(resource_ids):
        print(f"resource_types 数量({len(resource_types)})与 resource_ids 数量({len(resource_ids)})不一致，必须一一对应")
        exit(1)
    if resource_names and len(resource_names) != len(resource_ids):
        print(f"resource_names 数量({len(resource_names)})与 resource_ids 数量({len(resource_ids)})不一致，必须一一对应")
        exit(1)

    req_body = ProtectableAgentReq()
    agents = []
    for i, rid in enumerate(resource_ids):
        agent_res = ProtectableAgentStatusResource(resource_id=rid, resource_type=resource_types[i])
        if i < len(resource_names):
            agent_res.resource_name = resource_names[i]
        agents.append(agent_res)
    req_body.agent_status = agents

    request = CheckAgentRequest()
    request.body = req_body
    response = client.check_agent(request)

    agent_status = getattr(response, 'agent_status', []) or []

    if not agent_status:
        print(f"没有找到客户端状态信息 (区域: {Region})")
        exit(0)

    output = f"resource_id\tinstalled\tversion\tcode\tmessage\n"
    for agent in agent_status:
        resource_id = getattr(agent, 'resource_id', '')
        installed = getattr(agent, 'installed', '')
        version = getattr(agent, 'version', '')
        code = getattr(agent, 'code', '')
        message = getattr(agent, 'message', '')
        output += f"{resource_id}\t{installed}\t{version}\t{code}\t{message}\n"
    print(output)
except Exception as e:
    print(f"cbr.check_agent 查询失败: {e}")
    exit(1)

import argparse
import sys
import os

sys.path.insert(0, os.path.join(os.path.dirname(__file__), '..'))

from config import load_credentials, build_http_config
from huaweicloudsdkcore.auth.credentials import BasicCredentials
from huaweicloudsdkcbr.v1 import CbrClient
from huaweicloudsdkcbr.v1.model import ListAgentRequest
from huaweicloudsdkcbr.v1.region.cbr_region import CbrRegion

AK, SK, Region, SecurityToken = load_credentials()
Offset = 0

parser = argparse.ArgumentParser(description="查询 CBR 客户端列表")
parser.add_argument("--project_id", type=str, required=True, help="项目 ID")
parser.add_argument("--region", type=str, help="区域，默认 cn-north-4")
parser.add_argument("--limit", type=str, help="每页显示条目数，正整数")
parser.add_argument("--offset", type=int, help="本地渲染分页偏移量，从 0 开始")
parser.add_argument("--status", type=str, help="状态: normal/abnormal/uninstall")
parser.add_argument("--agent_id", type=str, help="客户端ID，多个以英文逗号分隔")
args = parser.parse_args()

if args.region is not None:
    Region = args.region

if args.offset is not None:
    Offset = args.offset

if Offset < 0:
    Offset = 0


def render(agents):
    total = len(agents)
    if Offset >= total:
        print(f"查询结果为空\n\n客户端列表共 {total} 个, 序号从 0 开始, offset必须 < {total}")
        exit(0)

    output = f"agent_id\tagent_version\tagent_type\thost_name\thost_ip\thost_os\tstatus\tlast_active_time\n"
    for i in range(Offset, min(total, Offset + 50)):
        agent = agents[i]
        agent_id = getattr(agent, 'agent_id', '')
        agent_version = getattr(agent, 'agent_version', '')
        agent_type = getattr(agent, 'agent_type', '')
        host_name = getattr(agent, 'host_name', '')
        host_ip = getattr(agent, 'host_ip', '')
        host_os = getattr(agent, 'host_os', '')
        status = getattr(agent, 'status', '')
        last_active_time = getattr(agent, 'last_active_time', '')
        output += f"{agent_id}\t{agent_version}\t{agent_type}\t{host_name}\t{host_ip}\t{host_os}\t{status}\t{last_active_time}\n"
    end = min(total, Offset + 50) - 1
    if total > 50 or Offset > 0:
        output += f"\n客户端列表共 {total} 个, 序号从 0 开始，当前显示第 {Offset}~{end} 个\n"
        if end + 1 < total:
            output += f"可以使用 --offset={end + 1} 参数继续获取后续数据"
    print(output)


try:
    http_config = build_http_config()

    client = CbrClient.new_builder().with_http_config(http_config).with_credentials(
        BasicCredentials(AK, SK, args.project_id) if not SecurityToken else BasicCredentials(AK, SK, args.project_id).with_security_token(SecurityToken)).with_region(CbrRegion.value_of(Region)).build()
    if not client:
        print(f"无法获取 CBR 客户端")
        exit(-1)

    request = ListAgentRequest()
    if args.limit:
        request.limit = args.limit
    if args.status:
        request.status = args.status
    if args.agent_id:
        request.agent_id = args.agent_id

    response = client.list_agent(request)
    agents = getattr(response, 'agents', []) or []
    count = getattr(response, 'count', 0)

    if not agents:
        print(f"没有找到客户端 (区域: {Region})")
        exit(0)

    render(agents)
except Exception as e:
    print(f"cbr.list_agent 查询失败: {e}")
    exit(1)

import argparse
import sys
import os

sys.path.insert(0, os.path.join(os.path.dirname(__file__), '..'))

from config import load_credentials, build_http_config
from huaweicloudsdkcore.auth.credentials import BasicCredentials
from huaweicloudsdkcbr.v1 import CbrClient
from huaweicloudsdkcbr.v1.model import ListBackupsRequest
from huaweicloudsdkcbr.v1.region.cbr_region import CbrRegion

AK, SK, Region, SecurityToken = load_credentials()
Offset = 0

parser = argparse.ArgumentParser(description="查询 CBR 备份列表")
parser.add_argument("--project_id", type=str, required=True, help="项目 ID")
parser.add_argument("--region", type=str, help="区域，默认 cn-north-4")
parser.add_argument("--checkpoint_id", type=str, help="还原点ID")
parser.add_argument("--dec", type=bool, help="是否专属")
parser.add_argument("--end_time", type=str, help="结束时间")
parser.add_argument("--image_type", type=str, help="备份类型")
parser.add_argument("--limit", type=int, default=1000, help="返回结果个数限制，默认1000")
parser.add_argument("--marker", type=str, help="分页标记")
parser.add_argument("--name", type=str, help="备份名称")
parser.add_argument("--offset", type=int, help="本地渲染分页偏移量，从 0 开始")
parser.add_argument("--resource_az", type=str, help="资源可用区")
parser.add_argument("--resource_id", type=str, help="资源ID")
parser.add_argument("--resource_name", type=str, help="资源名称")
parser.add_argument("--resource_type", type=str, help="资源类型")
parser.add_argument("--sort", type=str, help="排序")
parser.add_argument("--start_time", type=str, help="开始时间")
parser.add_argument("--status", type=str, help="状态")
parser.add_argument("--vault_id", type=str, help="存储库ID，可通过 list_vault.py 获取")
parser.add_argument("--enterprise_project_id", type=str, help="企业项目ID")
parser.add_argument("--own_type", type=str, help="所属类型")
parser.add_argument("--member_status", type=str, help="成员状态")
parser.add_argument("--parent_id", type=str, help="父备份ID")
parser.add_argument("--used_percent", type=str, help="使用百分比")
parser.add_argument("--show_replication", type=bool, help="是否显示复制")
parser.add_argument("--incremental", type=bool, help="是否增量备份")
args = parser.parse_args()

if args.region is not None:
    Region = args.region

if args.offset is not None:
    Offset = args.offset

if Offset < 0:
    Offset = 0


def render(backups):
    total = len(backups)
    if Offset >= total:
        print(f"查询结果为空\n\n备份列表共 {total} 个, 序号从 0 开始, offset必须 < {total}")
        exit(0)

    output = f"id\tname\tstatus\tresource_type\tresource_name\tresource_size(GB)\tvault_id\timage_type\tcreated_at\tincremental\n"
    for i in range(Offset, min(total, Offset + 50)):
        backup = backups[i]
        bid = getattr(backup, 'id', '')
        name = getattr(backup, 'name', '')
        status = getattr(backup, 'status', '')
        resource_type = getattr(backup, 'resource_type', '')
        resource_name = getattr(backup, 'resource_name', '')
        resource_size = getattr(backup, 'resource_size', '')
        vault_id = getattr(backup, 'vault_id', '')
        image_type = getattr(backup, 'image_type', '')
        created_at = getattr(backup, 'created_at', '')
        incremental = getattr(backup, 'incremental', '')
        output += f"{bid}\t{name}\t{status}\t{resource_type}\t{resource_name}\t{resource_size}\t{vault_id}\t{image_type}\t{created_at}\t{incremental}\n"
    end = min(total, Offset + 50) - 1
    if total > 50 or Offset > 0:
        output += f"\n备份列表共 {total} 个, 序号从 0 开始，当前显示第 {Offset}~{end} 个\n"
        if end + 1 < total:
            output += f"可以使用 --offset={end + 1} 参数继续获取后续数据"
    print(output)


try:
    http_config = build_http_config()

    client = CbrClient.new_builder().with_http_config(http_config).with_credentials(
        BasicCredentials(AK, SK, args.project_id) if not SecurityToken else BasicCredentials(AK, SK, args.project_id).with_security_token(SecurityToken)).with_region(CbrRegion.value_of(Region)).build()
    if not client:
        print(f"无法获取 CBR 客户端")
        exit(-1)

    request = ListBackupsRequest()
    request.limit = args.limit
    if args.checkpoint_id:
        request.checkpoint_id = args.checkpoint_id
    if args.dec:
        request.dec = args.dec
    if args.end_time:
        request.end_time = args.end_time
    if args.image_type:
        request.image_type = args.image_type
    if args.marker:
        request.marker = args.marker
    if args.name:
        request.name = args.name
    if args.resource_az:
        request.resource_az = args.resource_az
    if args.resource_id:
        request.resource_id = args.resource_id
    if args.resource_name:
        request.resource_name = args.resource_name
    if args.resource_type:
        request.resource_type = args.resource_type
    if args.sort:
        request.sort = args.sort
    if args.start_time:
        request.start_time = args.start_time
    if args.status:
        request.status = args.status
    if args.vault_id:
        request.vault_id = args.vault_id
    if args.enterprise_project_id:
        request.enterprise_project_id = args.enterprise_project_id
    if args.own_type:
        request.own_type = args.own_type
    if args.member_status:
        request.member_status = args.member_status
    if args.parent_id:
        request.parent_id = args.parent_id
    if args.used_percent:
        request.used_percent = args.used_percent
    if args.show_replication:
        request.show_replication = args.show_replication
    if args.incremental:
        request.incremental = args.incremental

    response = client.list_backups(request)
    backups = getattr(response, 'backups', []) or []
    count = getattr(response, 'count', 0)

    if not backups:
        print(f"没有找到备份 (区域: {Region})")
        exit(0)

    render(backups)
except Exception as e:
    print(f"cbr.list_backups 查询失败: {e}")
    exit(1)

import argparse
import sys
import os

sys.path.insert(0, os.path.join(os.path.dirname(__file__), '..'))

from config import load_credentials, build_http_config
from huaweicloudsdkcore.auth.credentials import BasicCredentials
from huaweicloudsdkcbr.v1 import CbrClient
from huaweicloudsdkcbr.v1.model import ListDomainProjectsRequest
from huaweicloudsdkcbr.v1.region.cbr_region import CbrRegion

AK, SK, Region, SecurityToken = load_credentials()

parser = argparse.ArgumentParser(description="查询租户项目列表")
parser.add_argument("--project_id", type=str, help="项目 ID")
parser.add_argument("--region", type=str, help="区域，默认 cn-north-4")
parser.add_argument("--domain_name", type=str, required=True, help="租户名称")
args = parser.parse_args()

if args.region is not None:
    Region = args.region

try:
    http_config = build_http_config()

    client = CbrClient.new_builder().with_http_config(http_config).with_credentials(
        BasicCredentials(AK, SK, args.project_id) if not SecurityToken else BasicCredentials(AK, SK, args.project_id).with_security_token(SecurityToken)).with_region(CbrRegion.value_of(Region)).build()
    if not client:
        print(f"无法获取 CBR 客户端")
        exit(-1)

    request = ListDomainProjectsRequest()
    request.domain_name = args.domain_name
    response = client.list_domain_projects(request)

    projects = getattr(response, 'projects', []) or []

    if not projects:
        print(f"没有找到域项目 (区域: {Region})")
        exit(0)

    output = f"project_id\tproject_name\n"
    for project in projects:
        project_id = getattr(project, 'project_id', '')
        project_name = getattr(project, 'project_name', '')
        output += f"{project_id}\t{project_name}\n"
    print(output)
except Exception as e:
    print(f"cbr.list_domain_projects 查询失败: {e}")
    exit(1)

import argparse
import sys
import os

sys.path.insert(0, os.path.join(os.path.dirname(__file__), '..'))

from config import load_credentials, build_http_config
from huaweicloudsdkcore.auth.credentials import BasicCredentials
from huaweicloudsdkcbr.v1 import CbrClient
from huaweicloudsdkcbr.v1.model import ListExternalVaultRequest
from huaweicloudsdkcbr.v1.region.cbr_region import CbrRegion

AK, SK, Region, SecurityToken = load_credentials()
Offset = 0

parser = argparse.ArgumentParser(description="查询 CBR 外部存储库列表")
parser.add_argument("--project_id", type=str, required=True, help="项目 ID")
parser.add_argument("--external_project_id", type=str, required=True, help="其他区域的项目ID")
parser.add_argument("--region", type=str, help="区域，默认 cn-north-4")
parser.add_argument("--limit", type=int, default=1000, help="返回结果个数限制，默认1000")
parser.add_argument("--offset", type=int, help="本地渲染分页偏移量，从 0 开始")
parser.add_argument("--protect_type", type=str, help="保护类型")
parser.add_argument("--region_id", type=str,  required=True, help="区域ID")
parser.add_argument("--objcet_type", type=str, help="资源类型（注意：SDK原始拼写为objcet_type）")
parser.add_argument("--cloud_type", type=str, help="云类型")
parser.add_argument("--vault_id", type=str, help="存储库ID")
args = parser.parse_args()

if args.region is not None:
    Region = args.region

if args.offset is not None:
    Offset = args.offset

if Offset < 0:
    Offset = 0


def render(vaults):
    total = len(vaults)
    if Offset >= total:
        print(f"查询结果为空\n\n外部存储库列表共 {total} 个, 序号从 0 开始, offset必须 < {total}")
        exit(0)

    output = f"id\tname\tstatus\tobject_type\tprotect_type\tsize(GB)\tused(MB)\tcreated_at\tavailability_zone\n"
    for i in range(Offset, min(total, Offset + 50)):
        vault = vaults[i]
        vid = getattr(vault, 'id', '')
        name = getattr(vault, 'name', '')
        created_at = getattr(vault, 'created_at', '')
        availability_zone = getattr(vault, 'availability_zone', '')
        billing = getattr(vault, 'billing', None)
        if billing:
            status = getattr(billing, 'status', '')
            object_type = getattr(billing, 'object_type', '')
            protect_type = getattr(billing, 'protect_type', '')
            size = getattr(billing, 'size', '')
            used = getattr(billing, 'used', '')
        else:
            status = ''
            object_type = ''
            protect_type = ''
            size = ''
            used = ''
        output += f"{vid}\t{name}\t{status}\t{object_type}\t{protect_type}\t{size}\t{used}\t{created_at}\t{availability_zone}\n"
    end = min(total, Offset + 50) - 1
    if total > 50 or Offset > 0:
        output += f"\n外部存储库列表共 {total} 个, 序号从 0 开始，当前显示第 {Offset}~{end} 个\n"
        if end + 1 < total:
            output += f"可以使用 --offset={end + 1} 参数继续获取后续数据"
    print(output)


try:
    http_config = build_http_config()

    client = CbrClient.new_builder().with_http_config(http_config).with_credentials(
        BasicCredentials(AK, SK, args.project_id) if not SecurityToken else BasicCredentials(AK, SK, args.project_id).with_security_token(SecurityToken)).with_region(CbrRegion.value_of(Region)).build()
    if not client:
        print(f"无法获取 CBR 客户端")
        exit(-1)

    request = ListExternalVaultRequest()
    request.external_project_id = args.external_project_id
    if args.limit:
        request.limit = args.limit
    if args.protect_type:
        request.protect_type = args.protect_type
    if args.region_id:
        request.region_id = args.region_id
    if args.objcet_type:
        request.objcet_type = args.objcet_type
    if args.cloud_type:
        request.cloud_type = args.cloud_type
    if args.vault_id:
        request.vault_id = args.vault_id

    response = client.list_external_vault(request)
    vaults = getattr(response, 'vaults', []) or []
    count = getattr(response, 'count', 0)

    if not vaults:
        print(f"没有找到外部存储库 (区域: {Region})")
        exit(0)

    render(vaults)
except Exception as e:
    print(f"cbr.list_external_vault 查询失败: {e}")
    exit(1)

import argparse
import sys
import os

sys.path.insert(0, os.path.join(os.path.dirname(__file__), '..'))

from config import load_credentials, build_http_config
from huaweicloudsdkcore.auth.credentials import BasicCredentials
from huaweicloudsdkcbr.v1 import CbrClient
from huaweicloudsdkcbr.v1.model import ListFeaturesRequest
from huaweicloudsdkcbr.v1.region.cbr_region import CbrRegion

AK, SK, Region, SecurityToken = load_credentials()

parser = argparse.ArgumentParser(description="查询 CBR 特性列表")
parser.add_argument("--project_id", type=str, required=True, help="项目 ID")
parser.add_argument("--region", type=str, help="区域，默认 cn-north-4")
parser.add_argument("--limit", type=int, help="返回结果个数限制")
parser.add_argument("--offset", type=int, help="偏移量")
args = parser.parse_args()

if args.region is not None:
    Region = args.region

try:
    http_config = build_http_config()

    client = CbrClient.new_builder().with_http_config(http_config).with_credentials(
        BasicCredentials(AK, SK, args.project_id) if not SecurityToken else BasicCredentials(AK, SK, args.project_id).with_security_token(SecurityToken)).with_region(CbrRegion.value_of(Region)).build()
    if not client:
        print(f"无法获取 CBR 客户端")
        exit(-1)

    request = ListFeaturesRequest()
    if args.limit:
        request.limit = args.limit
    if args.offset:
        request.offset = args.offset

    response = client.list_features(request)

    body = getattr(response, 'body', {})
    print(body)
except Exception as e:
    print(f"cbr.list_features 查询失败: {e}")
    exit(1)

import argparse
import sys
import os

sys.path.insert(0, os.path.join(os.path.dirname(__file__), '..'))

from config import load_credentials, build_http_config
from huaweicloudsdkcore.auth.credentials import BasicCredentials
from huaweicloudsdkcbr.v1 import CbrClient
from huaweicloudsdkcbr.v1.model import ListOpLogsRequest
from huaweicloudsdkcbr.v1.region.cbr_region import CbrRegion

AK, SK, Region, SecurityToken = load_credentials()
Offset = 0

parser = argparse.ArgumentParser(description="查询 CBR 任务列表")
parser.add_argument("--project_id", type=str, required=True, help="项目 ID")
parser.add_argument("--region", type=str, help="区域，默认 cn-north-4")
parser.add_argument("--end_time", type=str, help="结束时间")
parser.add_argument("--limit", type=int, default=1000, help="返回结果个数限制，默认1000")
parser.add_argument("--offset", type=int, help="本地渲染分页偏移量，从 0 开始")
parser.add_argument("--operation_type", type=str, help="任务类型")
parser.add_argument("--provider_id", type=str, help="备份提供商ID")
parser.add_argument("--resource_id", type=str, help="资源ID")
parser.add_argument("--resource_name", type=str, help="资源名称")
parser.add_argument("--start_time", type=str, help="开始时间")
parser.add_argument("--status", type=str, help="状态")
parser.add_argument("--vault_id", type=str, help="存储库ID，可通过 list_vault.py 获取")
parser.add_argument("--vault_name", type=str, help="存储库名称")
parser.add_argument("--enterprise_project_id", type=str, help="企业项目ID")
args = parser.parse_args()

if args.region is not None:
    Region = args.region

if args.offset is not None:
    Offset = args.offset

if Offset < 0:
    Offset = 0


def render(op_logs):
    total = len(op_logs)
    if Offset >= total:
        print(f"查询结果为空\n\n任务列表共 {total} 个, 序号从 0 开始, offset必须 < {total}")
        exit(0)

    output = f"id\toperation_type\tstatus\tprovider_id\tvault_id\tvault_name\tcreated_at\n"
    for i in range(Offset, min(total, Offset + 50)):
        log = op_logs[i]
        oid = getattr(log, 'id', '')
        operation_type = getattr(log, 'operation_type', '')
        status = getattr(log, 'status', '')
        provider_id = getattr(log, 'provider_id', '')
        vault_id = getattr(log, 'vault_id', '')
        vault_name = getattr(log, 'vault_name', '')
        created_at = getattr(log, 'created_at', '')
        output += f"{oid}\t{operation_type}\t{status}\t{provider_id}\t{vault_id}\t{vault_name}\t{created_at}\n"
    end = min(total, Offset + 50) - 1
    if total > 50 or Offset > 0:
        output += f"\n任务列表共 {total} 个, 序号从 0 开始，当前显示第 {Offset}~{end} 个\n"
        if end + 1 < total:
            output += f"可以使用 --offset={end + 1} 参数继续获取后续数据"
    print(output)


try:
    http_config = build_http_config()

    client = CbrClient.new_builder().with_http_config(http_config).with_credentials(
        BasicCredentials(AK, SK, args.project_id) if not SecurityToken else BasicCredentials(AK, SK, args.project_id).with_security_token(SecurityToken)).with_region(CbrRegion.value_of(Region)).build()
    if not client:
        print(f"无法获取 CBR 客户端")
        exit(-1)

    request = ListOpLogsRequest()
    request.limit = args.limit
    if args.end_time:
        request.end_time = args.end_time
    if args.operation_type:
        request.operation_type = args.operation_type
    if args.provider_id:
        request.provider_id = args.provider_id
    if args.resource_id:
        request.resource_id = args.resource_id
    if args.resource_name:
        request.resource_name = args.resource_name
    if args.start_time:
        request.start_time = args.start_time
    if args.status:
        request.status = args.status
    if args.vault_id:
        request.vault_id = args.vault_id
    if args.vault_name:
        request.vault_name = args.vault_name
    if args.enterprise_project_id:
        request.enterprise_project_id = args.enterprise_project_id

    response = client.list_op_logs(request)
    op_logs = getattr(response, 'operation_logs', []) or []
    count = getattr(response, 'count', 0)

    if not op_logs:
        print(f"没有找到任务(区域: {Region})")
        exit(0)

    render(op_logs)
except Exception as e:
    print(f"cbr.list_op_logs 查询失败: {e}")
    exit(1)

import argparse
import sys
import os

sys.path.insert(0, os.path.join(os.path.dirname(__file__), '..'))

from config import load_credentials, build_http_config
from huaweicloudsdkcore.auth.credentials import BasicCredentials
from huaweicloudsdkcbr.v1 import CbrClient
from huaweicloudsdkcbr.v1.model import ListOrganizationPoliciesRequest
from huaweicloudsdkcbr.v1.region.cbr_region import CbrRegion

AK, SK, Region, SecurityToken = load_credentials()
Offset = 0

parser = argparse.ArgumentParser(description="查询 CBR 组织策略列表")
parser.add_argument("--project_id", type=str, required=True, help="项目 ID")
parser.add_argument("--region", type=str, help="区域，默认 cn-north-4")
parser.add_argument("--operation_type", type=str, required=True, help="组织策略类型：备份（backup）、复制（replication）")
parser.add_argument("--limit", type=int, default=1000, help="返回结果个数限制，默认1000")
parser.add_argument("--offset", type=int, help="本地渲染分页偏移量，从 0 开始")
args = parser.parse_args()

if args.region is not None:
    Region = args.region

if args.offset is not None:
    Offset = args.offset

if Offset < 0:
    Offset = 0


def render(policies):
    total = len(policies)
    if Offset >= total:
        print(f"查询结果为空\n\n组织策略列表共 {total} 个, 序号从 0 开始, offset必须 < {total}")
        exit(0)

    output = f"id\tname\toperation_type\tpolicy_enabled\tstatus\n"
    for i in range(Offset, min(total, Offset + 50)):
        policy = policies[i]
        pid = getattr(policy, 'id', '')
        name = getattr(policy, 'name', '')
        operation_type = getattr(policy, 'operation_type', '')
        policy_enabled = getattr(policy, 'policy_enabled', '')
        status = getattr(policy, 'status', '')
        output += f"{pid}\t{name}\t{operation_type}\t{policy_enabled}\t{status}\n"
    end = min(total, Offset + 50) - 1
    if total > 50 or Offset > 0:
        output += f"\n组织策略列表共 {total} 个, 序号从 0 开始，当前显示第 {Offset}~{end} 个\n"
        if end + 1 < total:
            output += f"可以使用 --offset={end + 1} 参数继续获取后续数据"
    print(output)


try:
    http_config = build_http_config()

    client = CbrClient.new_builder().with_http_config(http_config).with_credentials(
        BasicCredentials(AK, SK, args.project_id) if not SecurityToken else BasicCredentials(AK, SK, args.project_id).with_security_token(SecurityToken)).with_region(CbrRegion.value_of(Region)).build()
    if not client:
        print(f"无法获取 CBR 客户端")
        exit(-1)

    request = ListOrganizationPoliciesRequest()
    if args.operation_type:
        request.operation_type = args.operation_type
    if args.limit:
        request.limit = args.limit

    response = client.list_organization_policies(request)
    policies = getattr(response, 'policies', []) or []
    count = getattr(response, 'count', 0)

    if not policies:
        print(f"没有找到组织策略 (区域: {Region})")
        exit(0)

    render(policies)
except Exception as e:
    print(f"cbr.list_organization_policies 查询失败: {e}")
    exit(1)

import argparse
import sys
import os

sys.path.insert(0, os.path.join(os.path.dirname(__file__), '..'))

from config import load_credentials, build_http_config
from huaweicloudsdkcore.auth.credentials import BasicCredentials
from huaweicloudsdkcbr.v1 import CbrClient
from huaweicloudsdkcbr.v1.model import ListOrganizationPolicyDetailRequest
from huaweicloudsdkcbr.v1.region.cbr_region import CbrRegion

AK, SK, Region, SecurityToken = load_credentials()

parser = argparse.ArgumentParser(description="查询组织策略部署状态列表")
parser.add_argument("--project_id", type=str, required=True, help="项目 ID")
parser.add_argument("--region", type=str, help="区域，默认 cn-north-4")
parser.add_argument("--organization_policy_id", type=str, required=True, help="组织策略ID")
args = parser.parse_args()

if args.region is not None:
    Region = args.region

try:
    http_config = build_http_config()

    client = CbrClient.new_builder().with_http_config(http_config).with_credentials(
        BasicCredentials(AK, SK, args.project_id) if not SecurityToken else BasicCredentials(AK, SK, args.project_id).with_security_token(SecurityToken)).with_region(CbrRegion.value_of(Region)).build()
    if not client:
        print(f"无法获取 CBR 客户端")
        exit(-1)

    request = ListOrganizationPolicyDetailRequest()
    request.organization_policy_id = args.organization_policy_id

    response = client.list_organization_policy_detail(request)
    policies = getattr(response, 'policies', []) or []
    count = getattr(response, 'count', 0)

    if not policies:
        print(f"没有找到组织策略详情 (区域: {Region})")
        exit(0)

    output = f"policy_id\tdomain_id\tproject_id\tstatus\n"
    for policy in policies:
        policy_id = getattr(policy, 'policy_id', '')
        domain_id = getattr(policy, 'domain_id', '')
        project_id = getattr(policy, 'project_id', '')
        status = getattr(policy, 'status', '')
        output += f"{policy_id}\t{domain_id}\t{project_id}\t{status}\n"
    print(output)
except Exception as e:
    print(f"cbr.list_organization_policy_detail 查询失败: {e}")
    exit(1)

import argparse
import sys
import os

sys.path.insert(0, os.path.join(os.path.dirname(__file__), '..'))

from config import load_credentials, build_http_config
from huaweicloudsdkcore.auth.credentials import BasicCredentials
from huaweicloudsdkcbr.v1 import CbrClient
from huaweicloudsdkcbr.v1.model import ListPoliciesRequest
from huaweicloudsdkcbr.v1.region.cbr_region import CbrRegion

AK, SK, Region, SecurityToken = load_credentials()

parser = argparse.ArgumentParser(description="查询 CBR 策略列表")
parser.add_argument("--project_id", type=str, required=True, help="项目 ID")
parser.add_argument("--region", type=str, help="区域，默认 cn-north-4")
parser.add_argument("--operation_type", type=str, help="策略类型：备份（backup）、复制(replication)")
parser.add_argument("--vault_id", type=str, help="存储库ID，可通过 list_vault.py 获取")
args = parser.parse_args()

if args.region is not None:
    Region = args.region

try:
    http_config = build_http_config()

    client = CbrClient.new_builder().with_http_config(http_config).with_credentials(
        BasicCredentials(AK, SK, args.project_id) if not SecurityToken else BasicCredentials(AK, SK, args.project_id).with_security_token(SecurityToken)).with_region(CbrRegion.value_of(Region)).build()
    if not client:
        print(f"无法获取 CBR 客户端")
        exit(-1)

    request = ListPoliciesRequest()
    if args.operation_type:
        request.operation_type = args.operation_type
    if args.vault_id:
        request.vault_id = args.vault_id

    response = client.list_policies(request)
    policies = getattr(response, 'policies', []) or []
    count = getattr(response, 'count', 0)

    if not policies:
        print(f"没有找到策略 (区域: {Region})")
        exit(0)

    output = f"id\tname\tenabled\toperation_type\tassociated_vaults_count\n"
    for policy in policies:
        pid = getattr(policy, 'id', '')
        name = getattr(policy, 'name', '')
        enabled = getattr(policy, 'enabled', '')
        operation_type = getattr(policy, 'operation_type', '')
        associated_vaults = getattr(policy, 'associated_vaults', []) or []
        output += f"{pid}\t{name}\t{enabled}\t{operation_type}\t{len(associated_vaults)}\n"
    print(output)
except Exception as e:
    print(f"cbr.list_policies 查询失败: {e}")
    exit(1)

import argparse
import sys
import os

sys.path.insert(0, os.path.join(os.path.dirname(__file__), '..'))

from config import load_credentials, build_http_config
from huaweicloudsdkcore.auth.credentials import BasicCredentials
from huaweicloudsdkcbr.v1 import CbrClient
from huaweicloudsdkcbr.v1.model import ListProjectsRequest
from huaweicloudsdkcbr.v1.region.cbr_region import CbrRegion

AK, SK, Region, SecurityToken = load_credentials()

parser = argparse.ArgumentParser(description="查询 CBR 项目列表")
parser.add_argument("--project_id", type=str, help="项目 ID")
parser.add_argument("--region", type=str, help="区域，默认 cn-north-4")
args = parser.parse_args()

if args.region is not None:
    Region = args.region

try:
    http_config = build_http_config()

    client = CbrClient.new_builder().with_http_config(http_config).with_credentials(
        BasicCredentials(AK, SK, args.project_id) if not SecurityToken else BasicCredentials(AK, SK, args.project_id).with_security_token(SecurityToken)).with_region(CbrRegion.value_of(Region)).build()
    if not client:
        print(f"无法获取 CBR 客户端")
        exit(-1)

    request = ListProjectsRequest()
    response = client.list_projects(request)

    projects = getattr(response, 'projects', []) or []

    if not projects:
        print(f"没有找到项目 (区域: {Region})")
        exit(0)

    output = f"id\tname\tdomain_id\tenabled\n"
    for project in projects:
        pid = getattr(project, 'id', '')
        name = getattr(project, 'name', '')
        domain_id = getattr(project, 'domain_id', '')
        enabled = getattr(project, 'enabled', '')
        output += f"{pid}\t{name}\t{domain_id}\t{enabled}\n"
    print(output)
except Exception as e:
    print(f"cbr.list_projects 查询失败: {e}")
    exit(1)

import argparse
import sys
import os

sys.path.insert(0, os.path.join(os.path.dirname(__file__), '..'))

from config import load_credentials, build_http_config
from huaweicloudsdkcore.auth.credentials import BasicCredentials
from huaweicloudsdkcbr.v1 import CbrClient
from huaweicloudsdkcbr.v1.model import ListProtectableRequest
from huaweicloudsdkcbr.v1.region.cbr_region import CbrRegion

AK, SK, Region, SecurityToken = load_credentials()
Offset = 0

parser = argparse.ArgumentParser(description="查询 CBR 可保护资源列表")
parser.add_argument("--project_id", type=str, required=True, help="项目 ID")
parser.add_argument("--region", type=str, help="区域，默认 cn-north-4")
parser.add_argument("--protectable_type", type=str, required=True, help="可保护资源类型，取值: server(云服务器类型), disk(云硬盘类型), turbo(turbo类型), workspace(workspace类型),workspace_v2(workspace_v2类型)")
parser.add_argument("--limit", type=int, default=1000, help="返回结果个数限制，默认1000")
parser.add_argument("--marker", type=str, help="分页标记")
parser.add_argument("--name", type=str, help="资源名称")
parser.add_argument("--offset", type=int, help="本地渲染分页偏移量，从 0 开始")
parser.add_argument("--status", type=str, help="状态")
parser.add_argument("--id", type=str, help="根据资源id过滤")
parser.add_argument("--server_id", type=str, help="云服务器ID")
args = parser.parse_args()

if args.region is not None:
    Region = args.region

if args.offset is not None:
    Offset = args.offset

if Offset < 0:
    Offset = 0


def render(instances):
    total = len(instances)
    if Offset >= total:
        print(f"查询结果为空\n\n可保护资源列表共 {total} 个, 序号从 0 开始, offset必须 < {total}")
        exit(0)

    output = f"id\tname\ttype\tsize(GB)\tstatus\n"
    for i in range(Offset, min(total, Offset + 50)):
        inst = instances[i]
        iid = getattr(inst, 'id', '')
        name = getattr(inst, 'name', '')
        itype = getattr(inst, 'type', '')
        size = getattr(inst, 'size', '')
        status = getattr(inst, 'status', '')
        output += f"{iid}\t{name}\t{itype}\t{size}\t{status}\n"
    end = min(total, Offset + 50) - 1
    if total > 50 or Offset > 0:
        output += f"\n可保护资源列表共 {total} 个, 序号从 0 开始，当前显示第 {Offset}~{end} 个\n"
        if end + 1 < total:
            output += f"可以使用 --offset={end + 1} 参数继续获取后续数据"
    print(output)


try:
    http_config = build_http_config()

    client = CbrClient.new_builder().with_http_config(http_config).with_credentials(
        BasicCredentials(AK, SK, args.project_id) if not SecurityToken else BasicCredentials(AK, SK, args.project_id).with_security_token(SecurityToken)).with_region(CbrRegion.value_of(Region)).build()
    if not client:
        print(f"无法获取 CBR 客户端")
        exit(-1)

    request = ListProtectableRequest()
    request.protectable_type = args.protectable_type
    request.limit = args.limit
    if args.marker:
        request.marker = args.marker
    if args.name:
        request.name = args.name
    if args.status:
        request.status = args.status
    if args.id:
        request.id = args.id
    if args.server_id:
        request.server_id = args.server_id

    response = client.list_protectable(request)
    instances = getattr(response, 'instances', []) or []

    if not instances:
        print(f"没有找到可保护资源 (区域: {Region})")
        exit(0)

    render(instances)
except Exception as e:
    print(f"cbr.list_protectable 查询失败: {e}")
    exit(1)

import argparse
import sys
import os

sys.path.insert(0, os.path.join(os.path.dirname(__file__), '..'))

from config import load_credentials, build_http_config
from huaweicloudsdkcore.auth.credentials import BasicCredentials
from huaweicloudsdkcbr.v1 import CbrClient
from huaweicloudsdkcbr.v1.model import ListVaultRequest
from huaweicloudsdkcbr.v1.region.cbr_region import CbrRegion

AK, SK, Region, SecurityToken = load_credentials()
Offset = 0

parser = argparse.ArgumentParser(description="查询 CBR 存储库列表")
parser.add_argument("--project_id", type=str, required=True, help="项目 ID")
parser.add_argument("--region", type=str, help="区域，默认 cn-north-4")
parser.add_argument("--limit", type=int, default=1000, help="返回结果个数限制，默认1000")
parser.add_argument("--name", type=str, help="存储库名称")
parser.add_argument("--offset", type=int, help="本地渲染分页偏移量，从 0 开始")
parser.add_argument("--cloud_type", type=str, help="云类型")
parser.add_argument("--protect_type", type=str, help="保护类型")
parser.add_argument("--object_type", type=str, help="对象类型：云服务器（server），云硬盘（disk），文件系统（turbo），云桌面（workspace），VMware（vmware），关系型数据库（rds），文件（file）")
parser.add_argument("--enterprise_project_id", type=str, help="企业项目id或all_granted_eps，可通过 ../eps/list_enterprise_projects.py 获取")
parser.add_argument("--id", type=str, help="存储库ID，多个以英文逗号分隔")
parser.add_argument("--policy_id", type=str, help="策略ID，可通过 list_policies.py 获取")
parser.add_argument("--status", type=str, help="状态")
parser.add_argument("--resource_ids", type=str, help="资源id，支持多资源，以英文逗号分隔")
args = parser.parse_args()

if args.region is not None:
    Region = args.region

if args.offset is not None:
    Offset = args.offset

if Offset < 0:
    Offset = 0

def render(vaults):
    total = len(vaults)
    if Offset >= total:
        print(f"查询结果为空\n\n存储库列表共 {total} 个, 序号从 0 开始, offset必须 < {total}")
        exit(0)

    output = f"id\tname\tstatus\tobject_type\tprotect_type\tsize(GB)\tused(MB)\tcreated_at\tavailability_zone\n"
    for i in range(Offset, min(total, Offset + 50)):
        vault = vaults[i]
        vid = getattr(vault, 'id', '')
        name = getattr(vault, 'name', '')
        created_at = getattr(vault, 'created_at', '')
        availability_zone = getattr(vault, 'availability_zone', '')
        billing = getattr(vault, 'billing', None)
        if billing:
            status = getattr(billing, 'status', '')
            object_type = getattr(billing, 'object_type', '')
            protect_type = getattr(billing, 'protect_type', '')
            size = getattr(billing, 'size', '')
            used = getattr(billing, 'used', '')
        else:
            status = ''
            object_type = ''
            protect_type = ''
            size = ''
            used = ''
        output += f"{vid}\t{name}\t{status}\t{object_type}\t{protect_type}\t{size}\t{used}\t{created_at}\t{availability_zone}\n"
    end = min(total, Offset + 50) - 1
    if total > 50 or Offset > 0:
        output += f"\n存储库列表共 {total} 个, 序号从 0 开始，当前显示第 {Offset}~{end} 个\n"
        if end + 1 < total:
            output += f"可以使用 --offset={end + 1} 参数继续获取后续数据"
    print(output)


try:
    http_config = build_http_config()

    client = CbrClient.new_builder().with_http_config(http_config).with_credentials(
        BasicCredentials(AK, SK, args.project_id) if not SecurityToken else BasicCredentials(AK, SK, args.project_id).with_security_token(SecurityToken)).with_region(CbrRegion.value_of(Region)).build()
    if not client:
        print(f"无法获取 CBR 客户端")
        exit(-1)

    all_vaults = []
    limit = args.limit

    request = ListVaultRequest()
    request.limit = limit
    if args.name:
        request.name = args.name
    if args.cloud_type:
        request.cloud_type = args.cloud_type
    if args.protect_type:
        request.protect_type = args.protect_type
    if args.object_type:
        request.object_type = args.object_type
    if args.enterprise_project_id:
        request.enterprise_project_id = args.enterprise_project_id
    if args.id:
        request.id = args.id
    if args.policy_id:
        request.policy_id = args.policy_id
    if args.status:
        request.status = args.status
    if args.resource_ids:
        request.resource_ids = args.resource_ids

    response = client.list_vault(request)
    vaults = getattr(response, 'vaults', []) or []
    count = getattr(response, 'count', 0)

    if not vaults:
        print(f"没有找到存储库 (区域: {Region})")
        exit(0)

    render(vaults)
except Exception as e:
    print(f"cbr.list_vault 查询失败: {e}")
    exit(1)

import argparse
import sys
import os

sys.path.insert(0, os.path.join(os.path.dirname(__file__), '..'))

from config import load_credentials, build_http_config
from huaweicloudsdkcore.auth.credentials import BasicCredentials
from huaweicloudsdkcbr.v1 import CbrClient
from huaweicloudsdkcbr.v1.model import ShowAgentRequest
from huaweicloudsdkcbr.v1.region.cbr_region import CbrRegion

AK, SK, Region, SecurityToken = load_credentials()

parser = argparse.ArgumentParser(description="查询 CBR 客户端详情")
parser.add_argument("--project_id", type=str, required=True, help="项目 ID")
parser.add_argument("--region", type=str, help="区域，默认 cn-north-4")
parser.add_argument("--agent_id", type=str, required=True, help="客户端ID，可通过 list_agent.py 获取")
args = parser.parse_args()

if args.region is not None:
    Region = args.region

try:
    http_config = build_http_config()

    client = CbrClient.new_builder().with_http_config(http_config).with_credentials(
        BasicCredentials(AK, SK, args.project_id) if not SecurityToken else BasicCredentials(AK, SK, args.project_id).with_security_token(SecurityToken)).with_region(CbrRegion.value_of(Region)).build()
    if not client:
        print(f"无法获取 CBR 客户端")
        exit(-1)

    request = ShowAgentRequest()
    request.agent_id = args.agent_id
    response = client.show_agent(request)
    agent = getattr(response, 'agent', None)

    if not agent:
        print(f"没有找到客户端 (区域: {Region}, 客户端 ID: {args.agent_id})")
        exit(0)

    output = ""
    output += f"agent_id: {getattr(agent, 'agent_id', '')}\n"
    output += f"agent_version: {getattr(agent, 'agent_version', '')}\n"
    output += f"agent_type: {getattr(agent, 'agent_type', '')}\n"
    output += f"host_name: {getattr(agent, 'host_name', '')}\n"
    output += f"host_nickname: {getattr(agent, 'host_nickname', '')}\n"
    output += f"host_ip: {getattr(agent, 'host_ip', '')}\n"
    output += f"host_os: {getattr(agent, 'host_os', '')}\n"
    output += f"status: {getattr(agent, 'status', '')}\n"
    output += f"last_active_time: {getattr(agent, 'last_active_time', '')}\n"
    output += f"created_at: {getattr(agent, 'created_at', '')}\n"
    output += f"updated_at: {getattr(agent, 'updated_at', '')}\n"

    paths = getattr(agent, 'paths', []) or []
    if paths:
        output += f"\npaths ({len(paths)}):\n"
        for path in paths:
            output += f"  id: {getattr(path, 'id', '')}\n"
            output += f"  dir_path: {getattr(path, 'dir_path', '')}\n"
            output += f"  status: {getattr(path, 'status', '')}\n"
            exclude_paths = getattr(path, 'exclude_paths', []) or []
            output += f"  exclude_paths: {exclude_paths}\n"

    print(output)
except Exception as e:
    print(f"cbr.show_agent 查询失败: {e}")
    exit(1)

import argparse
import sys
import os

sys.path.insert(0, os.path.join(os.path.dirname(__file__), '..'))

from config import load_credentials, build_http_config
from huaweicloudsdkcore.auth.credentials import BasicCredentials
from huaweicloudsdkcbr.v1 import CbrClient
from huaweicloudsdkcbr.v1.model import ShowBackupRequest
from huaweicloudsdkcbr.v1.region.cbr_region import CbrRegion

AK, SK, Region, SecurityToken = load_credentials()

parser = argparse.ArgumentParser(description="查询 CBR 备份详情")
parser.add_argument("--project_id", type=str, required=True, help="项目 ID")
parser.add_argument("--region", type=str, help="区域，默认 cn-north-4")
parser.add_argument("--backup_id", type=str, required=True, help="备份ID，可通过 list_backups.py 获取")
args = parser.parse_args()

if args.region is not None:
    Region = args.region

try:
    http_config = build_http_config()

    client = CbrClient.new_builder().with_http_config(http_config).with_credentials(
        BasicCredentials(AK, SK, args.project_id) if not SecurityToken else BasicCredentials(AK, SK, args.project_id).with_security_token(SecurityToken)).with_region(CbrRegion.value_of(Region)).build()
    if not client:
        print(f"无法获取 CBR 客户端")
        exit(-1)

    request = ShowBackupRequest()
    request.backup_id = args.backup_id
    response = client.show_backup(request)
    backup = getattr(response, 'backup', None)

    if not backup:
        print(f"没有找到备份 (区域: {Region}, 备份 ID: {args.backup_id})")
        exit(0)

    output = ""
    output += f"id: {getattr(backup, 'id', '')}\n"
    output += f"name: {getattr(backup, 'name', '')}\n"
    output += f"description: {getattr(backup, 'description', '')}\n"
    output += f"status: {getattr(backup, 'status', '')}\n"
    output += f"resource_id: {getattr(backup, 'resource_id', '')}\n"
    output += f"resource_name: {getattr(backup, 'resource_name', '')}\n"
    output += f"resource_type: {getattr(backup, 'resource_type', '')}\n"
    output += f"resource_size: {getattr(backup, 'resource_size', '')}\n"
    output += f"vault_id: {getattr(backup, 'vault_id', '')}\n"
    output += f"image_type: {getattr(backup, 'image_type', '')}\n"
    output += f"incremental: {getattr(backup, 'incremental', '')}\n"
    output += f"created_at: {getattr(backup, 'created_at', '')}\n"
    output += f"expired_at: {getattr(backup, 'expired_at', '')}\n"
    output += f"protected_at: {getattr(backup, 'protected_at', '')}\n"
    output += f"checkpoint_id: {getattr(backup, 'checkpoint_id', '')}\n"
    output += f"enterprise_project_id: {getattr(backup, 'enterprise_project_id', '')}\n"
    output += f"provider_id: {getattr(backup, 'provider_id', '')}\n"
    print(output)
except Exception as e:
    print(f"cbr.show_backup 查询失败: {e}")
    exit(1)