Project操作_数据总线 DataHub(DataHub)-阿里云帮助中心

本文为您展示DataHub的 Java SDK的Project操作。

创建Project

创建Project需要提供Project的名字和描述，Project的名字长度限制为[3,32]，必须以英文字母开头，仅允许英文字母、数字及“_”，大小写不敏感。

参数说明

参数名	参数类型	参数说明
projectName	String	项目名称。
comment	String	项目描述。

异常说明

异常类名	错误码	异常说明
DatahubClientException	-

代码示例

public static void createProject(String projectName,String projectComment) {
  try {
      datahubClient.createProject(projectName, projectComment);
      System.out.println("create project successful");
  } catch (DatahubClientException e) {
      System.out.println(e.getErrorMessage());
  }
}

删除Project

DataHub中通过API删除Project时，需确保Project中没有Topic，否则会抛出NoPermissionException异常。

参数说明

参数名	参数类型	参数说明
projectName	String	项目名称。

异常说明

异常类名

错误码

异常说明

DatahubClientException

并且是所有异常的基类

NoPermissionException

NoPermission

OperationDenied

没有权限，通常是RAM配置不正确，或没有正确授权子账号。

代码示例

public static void deleteProject(String projectName) {
  try {
      datahubClient.deleteProject(projectName);
      System.out.println("delete project successful");
  } catch (DatahubClientException e) {
      System.out.println(e.getErrorMessage());
  }
}

更新Project

DataHub通过API更新Project信息，可对comment内容进行更新。

参数说明

参数名	参数类型	参数说明
projectName	String	项目名称。
comment	String	项目描述。

异常说明

异常类名	错误码	异常说明
DatahubClientException	-

代码示例

public static void updateProject(String projectName,String newComment) {
    try {
        datahubClient.updateProject(projectName, newComment);
        System.out.println("update project successful");
    } catch (DatahubClientException e) {
        System.out.println("other error");
    }
}

列出Project

可查询出DataHub的以列表形式展示Project名称。

异常说明

异常类名	错误码	异常说明
DatahubClientException	-

代码示例

public static void listProject() {
    try {
        ListProjectResult listProjectResult = datahubClient.listProject();
        if (listProjectResult.getProjectNames().size() > 0) {
            for (String pName : listProjectResult.getProjectNames()) {
                System.out.println(pName);
            }
        }
    } catch (DatahubClientException e) {
        System.out.println(e.getErrorMessage());
    }
}

查询Project

参数说明

参数名	参数类型	参数说明
projectName	String	项目名称。

异常说明

异常类名	错误码	异常说明
DatahubClientException	-

代码示例

public static void getProject(String projectName) {
    try {
        GetProjectResult getProjectResult = datahubClient.getProject(projectName );
        System.out.println(getProjectResult.getCreateTime() + "\t"
                + getProjectResult.getLastModifyTime() + "\t"
                + getProjectResult.getComment());
    } catch (DatahubClientException e) {
        System.out.println(e.getErrorMessage());
    }
}