Project操作

更新时间:
复制为 MD 格式

本文为您展示DataHub的 GO SDKProject操作。

创建Project

参数说明

参数名

参数类型

参数说明

projectName

string

项目名称。

comment

string

项目描述。

错误说明

错误类型

错误码

错误说明

ResourceExistError

ResourceAlreadyExist

ProjectAlreadyExist

TopicAlreadyExist

ConnectorAlreadyExist

资源已存在(创建时如果资源已存在,就会抛出这个异常)。

AuthorizationFailedError

Unauthorized

Authorization 签名解析异常,检查AK是否填写正确。

DatahubClientError

-

其他所有,并且是所有异常的基类

InvalidParameterError

InvalidParameter

InvalidCursor

非法参数

代码示例

func createProjet(dh datahub.DataHub, projectName string) {
    if err := dh.CreateProject(projectName, "project comment"); err != nil {
        fmt.Println("create project failed")
        fmt.Println(err)
        return
    }
    fmt.Println("create successful")
}

删除Project

参数说明

参数名

参数类型

参数说明

projectName

string

项目名称。

错误说明

错误类型

错误码

错误说明

ResourceExistError

ResourceAlreadyExist

ProjectAlreadyExist

TopicAlreadyExist

ConnectorAlreadyExist

资源已存在(创建时如果资源已存在,就会抛出这个异常)。

AuthorizationFailedError

Unauthorized

Authorization 签名解析异常,检查AK是否填写正确。

DatahubClientError

-

其他所有,并且是所有异常的基类

InvalidParameterError

InvalidParameter

InvalidCursor

非法参数

代码示例

func deleteProject(dh datahub.DataHub, projectName string) {
    if err := dh.DeleteProject("123"); err != nil {
        fmt.Println("delete project failed")
        fmt.Println(err)
        return
    }
    fmt.Println("delete project successful")
}

列出Project

参数说明

参数名

参数类型

参数说明

projectName

string

项目名称。

返回示例

1. type ListProjectResult struct {
2.     ProjectNames []string `json:"ProjectNames"`
3. }

错误说明

错误类型

错误码

错误说明

AuthorizationFailedError

Unauthorized

Authorization 签名解析异常,检查AK是否填写正确。

DatahubClientError

-

其他所有,并且是所有异常的基类

代码示例

func listProject(dh datahub.DataHub, projectName string) {
    lp, err := dh.ListProject()
    if err != nil {
        fmt.Println("get project list failed")
        fmt.Println(err)
        return
    }
    fmt.Println("get project list successful")
    for _, projectName := range lp.ProjectNames {
        fmt.Println(projectName)
    }
}

查询Project

参数说明

参数名

参数类型

参数说明

projectName

string

项目名称

返回示例

type GetProjectResult struct {
    CreateTime     int64  `json:"CreateTime"`
    LastModifyTime int64  `json:"LastModifyTime"`
    Comment        string `json"Comment"`
}

错误说明

错误类型

错误码

错误说明

ResourceExistError

ResourceAlreadyExist

ProjectAlreadyExist

TopicAlreadyExist

ConnectorAlreadyExist

资源已存在(创建时如果资源已存在,就会抛出这个异常)。

AuthorizationFailedError

Unauthorized

Authorization 签名解析异常,检查AK是否填写正确。

DatahubClientError

-

其他所有,并且是所有异常的基类

InvalidParameterError

InvalidParameter

InvalidCursor

非法参数

代码示例

func getProject(dh datahub.DataHub, projectName string) {
    gp, err := dh.GetProject(projectName)
    if err != nil {
        fmt.Println("get project message failed")
        fmt.Println(err)
        return
    }
    fmt.Println("get project message successful")
    fmt.Println(*gp)
}

更新Project

参数说明

参数名

参数类型

参数说明

projectName

string

项目名称。

comment

string

项目描述。

错误说明

错误类型

错误码

错误说明

ResourceExistError

ResourceAlreadyExist

ProjectAlreadyExist

TopicAlreadyExist

ConnectorAlreadyExist

资源已存在(创建时如果资源已存在,就会抛出这个异常)。

AuthorizationFailedError

Unauthorized

Authorization 签名解析异常,检查AK是否填写正确。

DatahubClientError

-

其他所有,并且是所有异常的基类

InvalidParameterError

InvalidParameter

InvalidCursor

非法参数

代码示例

1. func updateProject(dh datahub.DataHub, projectName string) {
2.     if err := dh.UpdateProject(projectName, "new project comment"); err != nil {
3.         fmt.Println("update project comment failed")
4.         fmt.Println(err)
5.         return
6.     }
7.     fmt.Println("update project comment successful")
8. }