0. 版本说明

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

1. 示例简介

华为云提供了数据湖探索 DLI的SDK，您可以直接集成SDK来调用DLI的相关API，从而实现对标签管理的快速操作。 该示例展示了如何通过java版SDK查询所有队列。

2. 前置条件

• 1、获取华为云开发工具包（SDK），您也可以查看安装JAVA SDK。
• 2、您需要拥有华为云账号以及该账号对应的 Access Key（AK）和 Secret Access Key（SK）请在华为云控制台“我的凭证 > 访问密钥”页面上创建和查看您的AK/SK。具体请参见 访问密钥 。
• 3、华为云 Java SDK 支持 Java JDK 1.8 及其以上版本。

3. 安装SDK

您可以通过Maven方式获取和安装SDK，您只需要在Java项目的pom.xml文件中加入相应的依赖项即可。 具体的SDK版本号请参见 SDK开发中心 。

                    
                    Copied!
                
<dependencies>
    <dependency>
        <groupId>com.huaweicloud.sdk</groupId>
        <artifactId>huaweicloud-sdk-dli</artifactId>
        <version>3.1.33</version>
    </dependency>
</dependencies>

4.开始使用

创建查询所有队列示例代码

                    
                    Copied!
                
public class ListAllQueue {
    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");
        String iamEndpoint = "https://iam.cn-north-7.myhuaweicloud.com";  // 以乌兰三举例
        String dliEndpoint = "https://dli.cn-north-7.myhuaweicloud.com";     // 以乌兰三举例

        ICredential auth = new BasicCredentials()
                .withIamEndpoint(iamEndpoint)
                .withAk(ak)
                .withSk(sk);
        DliClient client = DliClient.newBuilder()
                .withCredential(auth)
                .withRegion(new Region("cn-north-7", dliEndpoint))
                .build();

        ListQueuesRequest request = new ListQueuesRequest();
        request.setQueueType("general");
        try {
            ListQueuesResponse response = client.listQueues(request);
            System.out.println(response.toString());
        } catch (ConnectionException e) {
            e.printStackTrace();
        } catch (RequestTimeoutException e) {
            e.printStackTrace();
        } catch (ServiceResponseException e) {
            e.printStackTrace();
            System.out.println(e.getHttpStatusCode());
            System.out.println(e.getErrorCode());
            System.out.println(e.getErrorMsg());
        }
    }
}

5. 返回示例

查询所有队列

                    
                    Copied!
                
{
  "queues": [
    {
      "queue_name": "test",
      "owner": "testuser",
      "description": "",
      "create_time": 1562221422671,
      "queue_type": "spark",
      "cu_count": 16,
      "charging_mode": 2
    }
  ]
}

6.接口及参数说明

参见：查询所有队列

7. 参考

更多示例信息请参考数据湖探索 DLI

8. 修订记录