华为云用户手册

  • 新建自定义作业 DLI 提供新建Flink自定义作业的接口。您可以使用该接口创建一个用户自定义作业,目前支持jar格式,运行在独享队列中。示例代码如下: 1 2 3 4 5 6 7 8 910 private static void createFlinkJob(DLIClient client) throws DLIException { CreateFlinkJarJobRequest body = new CreateFlinkJarJobRequest(); body.name("jar-job"); body.cuNumber(2); body.managerCuNumber(1); body.parallelNumber(1); body.entrypoint("dli/WindowJoin.jar"); JobStatusResponse result = client.createFlinkJarJob(body); System.out.println(result); }
  • 更新SQL作业 DLI提供更新Flink SQL作业接口。您可以使用该接口更新Flink SQL作业,示例代码如下: 123456 private static void updateSQLJob(DLIClient client) throws DLIException { UpdateFlinkSqlJobRequest body = new UpdateFlinkSqlJobRequest(); body.name("update-job"); JobUpdateResponse result = client.updateFlinkSqlJob(body,203L); System.out.println(result); }
  • 查询作业APIG网关服务访问地址 DLI提供查询Flink作业APIG访问地址的接口。您可以使用该接口查询作业APIG网关服务访问地址。示例代码如下: 12345 private static void getFlinkApigSinks(DLIClient client) throws DLIException { Long jobId = 59L;//作业1ID FlinkJobApigSinksResponse result = client.getFlinkApigSinks(jobId); System.out.println(result); }
  • 新建SQL作业 DLI提供新建Flink SQL作业的接口。您可以使用该接口新建Flink SQL作业并提交到DLI,示例代码如下: 1 2 3 4 5 6 7 8 910 private static void createSQLJob(DLIClient client) throws DLIException { SubmitFlinkSqlJobRequest body = new SubmitFlinkSqlJobRequest(); body.name("job-name"); body.runMode(SubmitFlinkSqlJobRequest.RunModeEnum.SHARED_CLUSTER); body.checkpointEnabled(false); body.checkpointMode(1); body.jobType(SubmitFlinkSqlJobRequest.JobTypeEnum.JOB); JobStatusResponse result = client.submitFlinkSqlJob(body); System.out.println(result);}
  • 查询作业列表 DLI提供查询Flink作业列表的接口。您可以使用该接口查询作业列表。作业列表查询支持以下参数: name,status,show_detail,cursor,next,limit,order。本示例排序方式选择降序desc,将会列出作业id小于cursor的作业列表信息。示例代码如下: 1234 private static void QueryFlinkJobListResponse(DLIClient client) throws DLIException { QueryFlinkJobListResponse result = client.getFlinkJobs(null, "job_init", null, true, 0L, 10, null, null,null,null,null); System.out.println(result); }
  • 查询作业详情 DLI提供查询Flink作业详情的接口。您可以使用该接口查询作业的详情。示例代码如下: 12345 private static void getFlinkJobDetail(DLIClient client) throws DLIException {Long jobId = 203L;//作业ID GetFlinkJobDetailResponse result = client.getFlinkJobDetail(jobId); System.out.println(result);}
  • 查询作业执行计划图 DLI提供查询Flink作业执行计划图的接口。您可以使用该接口查询作业的执行计划图。示例代码如下: 12345 private static void getFlinkJobExecuteGraph(DLIClient client) throws DLIException {Long jobId = 203L;//作业ID FlinkJobExecutePlanResponse result = client.getFlinkJobExecuteGraph(jobId); System.out.println(result); }
  • 查询作业模板列表 DLI提供查询Flink作业模板的接口。您可以使用该接口查询作业模板列表。本示例排序方式选择降序desc,将会列出作业模板ID小于cursor的作业模板列表信息。示例代码如下: 1234567 public static void getFlinkJobTemplates(DLIClient client) throws DLIException{ Long offset = 789L; // Long | 模板偏移量。 Integer limit = 56; // Integer | 查询条数限制 String order = "asc"; // String | 查询结果排序, 升序和降序两种可选 FlinkJobTemplateListResponse result = client.getFlinkJobTemplates(offset,limit,order); System.out.println(result); }
  • 更新作业模板 DLI提供更新Flink作业模板的接口。您可以使用该接口修改一个Flink作业模板。示例代码如下: 1234567 public static void updateFlinkJobTemplate(DLIClient client) throws DLIException{ Long templateId = 277L;//模板Id UpdateFlinkJobTemplateRequest body = new UpdateFlinkJobTemplateRequest(); body.name("template-update"); GlobalResponse result = client.updateFlinkJobTemplate(body,templateId); System.out.println(result); }
  • 删除作业模板 DLI提供删除Flink作业模板的接口。您可以使用该接口删除已经创建的作业模板,如果当前模板被引用也允许删除模板。示例代码如下: 12345 public static void deleteFlinkJobTemplate(DLIClient client) throws DLIException{ Long templateId = 277L;//模板Id FlinkJobTemplateDeleteResponse result = client.deleteFlinkJobTemplate(templateId); System.out.println(result);}
  • 新建作业模板 DLI提供新建Flink作业模板的接口。您可以使用该接口新建一个Flink作业模板。示例代码如下: 123456 public static void createFlinkJobTemplate(DLIClient client) throws DLIException{ CreateFlinkJobTemplateRequest body = new CreateFlinkJobTemplateRequest(); body.name("template"); FlinkJobTemplateCreateResponse result = client.createFlinkJobTemplate(body); System.out.println(result);}
  • 创建数据库 DLI提供创建数据库的接口。您可以使用该接口创建数据库,示例代码如下: 1234567 private static Database createDatabase(DLIClient client) throws DLIException { //通过调用DLIClient对象的createDatabase方法创建数据库 String dbName = "databasename"; Database database = client.createDatabase(dbName); System.out.println("create database:" + database); return database; } “default”为内置数据库,不能创建名为“default”的数据库。
  • 删除数据库 DLI提供删除数据库的接口。您可以使用该接口删除数据库。示例代码如下: 12345678 //调用Database对象的deleteDatabase接口删除数据库,//其中Database对象通过调用对象DLIClient的getDatabase(String databaseName)接口获得.private static void deletedatabase(Database database) throws DLIException { String dbName = "databasename"; database=client.getDatabase(dbName); database.deleteDatabase(); System.out.println("delete db " + dbName);} 含表的数据库不能直接删除,请先删除数据库的表再删除数据库。 数据库删除后,将不可恢复,请谨慎操作。
  • SDK列表 表1提供了各个云服务支持的SDK列表,您可以在GitHub仓库查看SDK更新历史、获取安装包以及查看指导文档。 表1 SDK列表 编程语言 Github地址 参考文档 视频指导 Java huaweicloud-sdk-java-v3 Java SDK使用指导 Java SDK视频指导 Python huaweicloud-sdk-python-v3 Python SDK使用指导 Python SDK视频指导 PHP huaweicloud-sdk-php-v3 PHP SDK使用指导 PHP SDK视频指导 Go huaweicloud-sdk-go-v3 Go SDK使用指导 Go SDK视频指导 Node.js huaweicloud-sdk-nodejs-v3 Node.js SDK使用指导 Node.js SDK视频指导 .NET huaweicloud-sdk-net-v3 .NET SDK使用指导 .NET SDK视频指导
  • 参数描述 参数 是否必须 类型 描述 page 是 String 用于定义scheme功能,取值为launch。 nonce 是 String 入会身份鉴权的nonce。 nonce获取方式说明:首先调用服务器登录鉴权API“执行App ID鉴权”获取到token;然后调用服务器API“获取页面免登录跳转的nonce信息”获取nonce,详见FAQ。 nonce必须传入有效值,否则登录失败。nonce获取之后,只能使用一次。
  • 参数描述 参数 是否必须 类型 描述 page 是 String 用于定义scheme功能,取值为launch。 nonce 是 String 入会身份鉴权的nonce。 nonce获取方式说明:首先调用服务器登录鉴权API“执行App ID鉴权”获取到token;然后调用服务器API“获取页面免登录跳转的nonce信息”获取nonce,详见FAQ。 nonce必须传入有效值,否则登录失败。nonce获取之后,只能使用一次。
  • 代码示例 - (void)handleEventWithNonce:(NSString *)nonce { NSString * schemeStr = [NSString stringWithFormat:@"cloudlink://welinksoftclient/h5page?page=launch&nonce=%@", nonce]; NSLog(@"schemeStr:%@", schemeStr); NSURL *schemUrl = [[NSURL alloc] initWithString:[schemeStr stringByAddingPercentEncodingWithAllowedCharacters:[NSCharacterSet URLQueryAllowedCharacterSet]]]; [[NSWorkspace sharedWorkspace] openURL:schemUrl];} 上述代码示例仅作为逻辑示例,不能直接使用。
  • 参数描述 参数 是否必须 类型 描述 page 是 String 用于定义scheme功能,取值为launch。 nonce 是 String 入会身份鉴权的nonce。 nonce获取方式说明:首先调用服务器登录鉴权API“执行App ID鉴权”获取到token;然后调用服务器API“获取页面免登录跳转的nonce信息”获取nonce,详见FAQ。 nonce必须传入有效值,否则登录失败。nonce获取之后,只能使用一次。
  • 代码示例 //匿名入会- (void)joinConfWithoutLogin:(id)sender {//这里以从界面TextField上获取信息 NSString *server_url = 服务器地址; NSString *port = 服务器端口; NSString *confId = 会议ID; NSString *enter_code = 会议enter_code; NSString *name = 入会姓名; NSString *open_mic = 麦克风开关 ? @"true" : @"false"; NSString *open_camera = 摄像头开关 ? @"true" : @"false"; NSString *joinConfString = [NSString stringWithFormat:@"cloudlink://welinksoftclient/h5page?page=joinTmpConfByLink&server_url=%@&port=%@&conf_id=%@&enter_code=%@&name=%@&open_mic=%@&open_camera=%@", server_url, port, confId, enter_code, name, open_mic, open_camera]; NSURL *joinConfUrl = [NSURL URLWithString:joinConfString]; [[NSWorkspace sharedWorkspace] openURL:joinConfUrl];} 上述代码示例仅作为逻辑示例,不能直接使用。
  • 终端Scheme应用集成概述 在已经安装华为云会议App的前提下,第三方Web应用或者第三方App,按照华为云会议App定义的URL Protocol,可以: 启动华为云会议App后进入待登录界面 启动华为云会议App并完成登录后进入主界面 以华为云会议App当前登录的账号(或者匿名)加入会议 启动华为云会议App完成登录后加入会议 图1 Web应用上拉起Windows版华为云会议App并加入会议
  • 链接格式 1 cloudlink://welinksoftclient/h5page?page=LoginAndJoinConf&server_url=meeting.huaweicloud.com&port=8443&conf_id=12345&enter_code=12345&name=Tom&open_mic=true&open_camera=false&nonce=Ey************************************pQ
  • 参数描述 参数 是否必须 类型 描述 page 是 String 用于定义scheme功能,取值为LoginAndJoinConf。 server_url 否 String 服务器地址,为空使用华为云会议默认服务器地址。 中国站:meeting.huaweicloud.com 国际站:intl.meeting.huaweicloud.com port 否 String 服务器端口,为空使用华为云会议默认端口。 conf_id 是 String 会议ID。 enter_code 否 String 会议密码。 name 是 String 会议中的显示名称。 open_mic 否 String 是否开启麦克风,true开启,false关闭,不填默认关闭。 open_camera 否 String 是否开启摄像头,true开启,false关闭,不填默认关闭。 nonce 是 String 入会身份鉴权的nonce。 若希望以主持人身份入会,enter_code必须传入主持人密码。若希望以来宾身份入会,当会议要求来宾密码时,enter_code必须传入来宾密码,会议不要求来宾密码时,可以不传。 nonce获取方式说明:首先调用服务器登录鉴权API“执行App ID鉴权”获取到token;然后调用服务器API“获取页面免登录跳转的nonce信息”获取nonce,详见FAQ。 nonce必须传入有效值,否则入会失败。nonce获取之后,只能使用一次。
  • 代码示例 1 2 3 4 5 6 7 8 9101112131415 Uri.Builder builder = new Uri.Builder() .scheme("cloudlink") .authority("welinksoftclient") .path("h5page") .appendQueryParameter("page","joinConfByLink") .appendQueryParameter("server_url",serverAddress) .appendQueryParameter("port",portString) .appendQueryParameter("conf_id",confId) .appendQueryParameter("enter_code",enterCode) .appendQueryParameter("name",name) .appendQueryParameter("open_mic",String.valueOf(openMic)) .appendQueryParameter("open_camera",String.valueOf(openCamera)); Intent intent = new Intent();intent.setData(Uri.parse(url));startActivity(intent);
  • 代码示例 //拉起应用- (void)launchCloudLinkMeeting { NSURL *launchUrl = [NSURL URLWithString:@"cloudlink://welinksoftclient/h5page?page=launch"]; [[UIApplication sharedApplication] openURL:launchUrl options:@{} completionHandler:nil];}
  • 参数描述 参数 是否必须 类型 描述 page 是 String 用于定义scheme功能,取值为launch。 nonce 是 String 入会身份鉴权的nonce nonce获取方式说明:首先调用服务器登录鉴权API“执行App ID鉴权”获取到token;然后调用服务器API“获取页面免登录跳转的nonce信息”获取nonce,详见FAQ。 nonce必须传入有效值,否则登录失败。nonce获取之后,只能使用一次。
  • 参数描述 表1 scheme参数说明 参数 是否必须 类型 描述 page 是 字符串 用于定义scheme功能,取值为joinConfByLink。 server_url 否 字符串 服务器地址,为空使用默认值。 中国站:meeting.huaweicloud.com 国际站:intl.meeting.huaweicloud.com port 否 字符串 服务器端口,为空使用默认值。 conf_id 是 字符串 会议ID。 enter_code 否 字符串 会议密码。 name 是 字符串 显示名称。 open_mic 否 字符串 是否开启麦克风,true开启,false关闭,不填默认开启。 open_camera 否 字符串 是否开启摄像头,true开启,false关闭,不填默认开启。 上述所有参数均以字符串直接传入,无需二次编码。若希望以主持人身份入会,enter_code必须传入主持人密码。若希望以来宾身份入会,当会议要求来宾密码时,enter_code必须传入来宾密码,会议不要求来宾密码时,可以不用传。
  • 参数描述 参数 是否必须 类型 描述 page 是 String 用于定义scheme功能,取值为LoginAndJoinConf。 server_url 否 String 服务器地址,为空使用华为云会议默认服务器地址。 port 否 String 服务器端口,为空使用华为云会议默认端口。 conf_id 是 String 会议ID。 enter_code 否 String 会议密码。 name 是 String 会议中的显示名称。 open_mic 否 String 是否开启麦克风,不填默认关闭。 open_camera 否 String 是否开启摄像头,不填默认关闭。 nonce 是 String 入会身份鉴权的nonce。
  • 代码示例 - (void)joinConfWithoutLogin:(id)sender {//这里以从界面TextField上获取信息 NSString *server_url = 服务器地址; NSString *port = 服务器端口; NSString *confId = 会议ID; NSString *enter_code = 会议密码; NSString *name = 入会姓名; NSString *open_mic = 麦克风开关 ? @"true" : @"false"; NSString *open_camera = 摄像头开关 ? @"true" : @"false"; NSString * nonceStr = 服务器接口获取的nonce; NSString *joinConfString = [NSString stringWithFormat:@"cloudlink://welinksoftclient/h5page?page=joinConfByLink&server_url=%@&port=%@&conf_id=%@&enter_code=%@&name=%@&open_mic=%@&open_camera=%@&nonce=%@", server_url, port, confId, enter_code, name, open_mic, open_camera, nonce]; NSURL *joinConfUrl = [NSURL URLWithString:joinConfString]; [[UIApplication sharedApplication] openURL:joinConfUrl options:@{} completionHandler:nil];} 上述代码示例仅作为逻辑示例,不能直接使用。
  • 链接格式 cloudlink://welinksoftclient/h5page?page=LoginAndJoinConf&server_url=meeting.huaweicloud.com&port=8443&conf_id=12345&enter_code=12345&name=Tom&open_mic=true&open_camera=false&nonce=Ey************************************pQ
  • 参数描述 表1 scheme参数说明 参数 是否必须 类型 描述 page 是 字符串 用于定义scheme功能,取值为joinConfByLink。 server_url 否 字符串 服务器地址,为空使用默认值 中国站:meeting.huaweicloud.com 国际站:intl.meeting.huaweicloud.com port 否 字符串 服务器端口,为空使用默认值。 conf_id 是 字符串 会议ID enter_code 否 字符串 会议密码 name 是 字符串 显示名称 open_mic 否 字符串 是否开启麦克风,true开启,false关闭,不填默认关闭 open_camera 否 字符串 是否开启摄像头,true开启,false关闭,不填默认关闭 若希望以主持人身份入会,enter_code必须传入主持人密码。若希望以来宾身份入会,当会议要求来宾密码时,enter_code必须传入来宾密码,会议不要求来宾密码时,可以不用传。
共99316条