版本说明

本示例基于华为云SDK V3.0版本开发

功能介绍

数据湖治理中心开发工具包（Data Lake Governance Center Software Development Kit，简称DGC SDK）是对数据湖治理中心提供的REST API进行的封装，以简化用户的开发工作。用户通过添加依赖或下载的方式调用API即可实现使用数据湖治理中心业务能力的目的。

该示例展示了如何通过java版SDK实现数据湖治理中心的查询作业列表功能。

前置条件

注册账户

注册 华为云，并完成 实名认证 。

申请服务

数据湖治理中心服务的具体操作步骤请参见《数据湖治理中心帮助文档》的“准备工作 > 购买DGC实例 ”章节。

获取AK/SK

开发者在使用前需先获取账号的ak、sk、endpoint。

您需要拥有华为云账号以及该账号对应的 Access Key（AK）和 Secret Access Key（SK）。请在华为云控制台“我的凭证 > 访问密钥”页面上创建和查看您的AK/SK。具体请参见 访问密钥 。 endpoint 华为云各服务应用区域和各服务的终端节点，详情请查看地区和终端节点 。

运行环境

Java JDK 1.8 及其以上版本，推荐通过Maven 安装依赖的方式使用JAVA版本SDK。

SDK获取和安装

在Maven 项目的 pom.xml 文件加入相应版本的依赖项即可。

以引入3.0.73版本的数据湖治理中心SDK为例：

                    
                    Copied!
                
<dependency>
    <groupId>com.huaweicloud.sdk</groupId>
    <artifactId>huaweicloud-sdk-cdm</artifactId>
    <version>3.0.73</version>
</dependency>

示例代码因需要输出结果更直观，所以新增fastjson的依赖（如接入不涉及此项，可忽略并在示例代码中删除相关内容），依赖如下：

                    
                    Copied!
                
<dependency>
	<groupId>com.alibaba</groupId>
	<artifactId>fastjson</artifactId>
	<version>1.2.70</version>
</dependency>

示例代码

数据湖治理中心(DGC)示例代码只需将AK/SK信息替换为实际AK/SK，完成后运行即可。

                    
                    Copied!
                
import com.alibaba.fastjson.JSON;

import com.huaweicloud.sdk.core.auth.ICredential;
import com.huaweicloud.sdk.core.auth.BasicCredentials;
import com.huaweicloud.sdk.core.exception.ConnectionException;
import com.huaweicloud.sdk.core.exception.RequestTimeoutException;
import com.huaweicloud.sdk.core.exception.ServiceResponseException;
import com.huaweicloud.sdk.dgc.v1.DgcClient;
import com.huaweicloud.sdk.dgc.v1.region.DgcRegion;
import com.huaweicloud.sdk.dgc.v1.model.ListJobsRequest;
import com.huaweicloud.sdk.dgc.v1.model.ListJobsResponse;


public class ListJobs {
    public static void main(String[] args) {
        // 认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全；
        // 本示例以ak和sk保存在环境变量中来实现身份认证为例，运行示例前请先在本地环境中设置环境变量HUAWEICLOUD_SDK_AK和HUAWEICLOUD_SDK_SK。
        String ak = System.getenv("HUAWEICLOUD_SDK_AK");
        String sk = System.getenv("HUAWEICLOUD_SDK_SK");
        ICredential auth = new BasicCredentials()
                .withAk(ak)
                .withSk(sk);

        DgcClient client = DgcClient.newBuilder()
                .withCredential(auth)
                .withRegion(DgcRegion.valueOf("cn-north-4"))
                .build();
        ListJobsRequest request = new ListJobsRequest();
        try {
            ListJobsResponse response = client.listJobs(request);
            System.out.println(response.getHttpStatusCode());
            System.out.println(JSON.toJSONString(response));
        } catch (ConnectionException e) {
            System.out.println(e.getMessage());
        } catch (RequestTimeoutException e) {
            System.out.println(e.getMessage());
        } catch (ServiceResponseException e) {
            System.out.println(e.getHttpStatusCode());
            System.out.println(e.getErrorCode());
            System.out.println(e.getErrorMsg());
        }
    }
}

参考

更多信息请参考数据湖治理中心

修订记录