华为云用户手册

翻拍识别示例 本章节对翻拍识别AK/SK方式使用SDK进行示例说明。 翻拍识别示例代码只需将AK/SK信息替换为实际AK/SK，代码中可以使用初始化RunRecaptureDetectReq中的url或image配置图像信息（image和url参数二选一），示例中以url为例，配置完成后运行即可。 endpoint是华为云各服务应用区域和各服务的终端节点，详情请查看地区和终端节点 。 翻拍识别调用示例代码如下： # coding: utf-8 from huaweicloudsdkcore.auth.credentials import BasicCredentials from huaweicloudsdkimage.v2.region.image_region import ImageRegion from huaweicloudsdkcore.exceptions import exceptions from huaweicloudsdkimage.v2 import * if __name__ == "__main__": # 认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全； # 本示例以ak和sk保存在环境变量中来实现身份验证为例，运行本示例前请先在本地环境中设置环境变量HUAWEICLOUD_SDK_AK和HUAWEICLOUD_SDK_SK。 ak = os.getenv("HUAWEICLOUD_SDK_AK") sk = os.getenv("HUAWEICLOUD_SDK_SK") credentials = BasicCredentials(ak, sk) \ client = ImageClient.new_builder() \ .with_credentials(credentials) \ .with_region(ImageRegion.value_of("cn-north-4")) \ //此处替换为您开通服务的区域 .build() try: request = RunRecaptureDetectRequest() request.body = RecaptureDetectReq( threshold=0, url="https://bucketname.obs.cn-north-4.myhuaweicloud.com/image/test1.jpg"//替换为公网可以访问的图片地址 ) response = client.run_recapture_detect(request) print(response) except exceptions.ClientRequestException as e: print(e.status_code) print(e.request_id) print(e.error_code) print(e.error_msg) 执行示例代码文件，控制台输出翻拍识别结果即表示程序执行成功。 {"result":{"suggestion":"false","category":"recapture","score":"0.9998","detail":[{"label":"recapture","confidence":"0.9998"}]}} 父主题： 使用SDK（Python）

图像标签示例 本章节对图像标签AK/SK方式使用SDK进行示例说明。 图像标签示例代码只需将AK/SK信息替换为实际AK/SK，代码中可以使用初始化ImageTaggingReq中的url或image配置图像信息（image和url参数二选一），示例中以url为例，配置完成后运行即可。 endpoint是华为云各服务应用区域和各服务的终端节点，详情请查看 地区和终端节点 。 图像标签调用示例代码如下： using System; using System.Collections.Generic; using HuaweiCloud.SDK.Core; using HuaweiCloud.SDK.Core.Auth; using HuaweiCloud.SDK.Image; using HuaweiCloud.SDK.Image.V2; using HuaweiCloud.SDK.Image.V2.Model; using Newtonsoft.Json; namespace RunImageTaggingSolution { class Program { static void Main(string[] args) { //认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全 //本示例以ak和sk保存在环境变量中来实现身份验证为例，运行本示例前请先在本地环境中设置环境变量HUAWEICLOUD_SDK_AK和HUAWEICLOUD_SDK_SK string accessKey= Environment.GetEnvironmentVariable("HUAWEICLOUD_SDK_AK", EnvironmentVariableTarget.Machine); string secretKey= Environment.GetEnvironmentVariable("HUAWEICLOUD_SDK_SK", EnvironmentVariableTarget.Machine); var config = HttpConfig.GetDefaultConfig(); config.IgnoreSslVerification = true; var auth = new BasicCredentials(ak, sk); var client = ImageClient.NewBuilder() .WithCredential(auth) .WithRegion(ImageRegion.ValueOf("cn-north-1")) //此处替换为您开通服务的区域 .WithHttpConfig(config) .Build(); var req = new RunImageTaggingRequest { }; req.Body = new ImageTaggingReq() { Limit = 50, Threshold = 95, Language = "zh", Url = "https://XXX.jpg" //此处替换为公网可以访问的图片地址 }; try { var resp = client.RunImageTagging(req); var respStatusCode = resp.HttpStatusCode; Console.WriteLine(respStatusCode); Console.WriteLine(JsonConvert.DeserializeObject(resp.HttpBody)); } catch (RequestTimeoutException requestTimeoutException) { Console.WriteLine(requestTimeoutException.ErrorMessage); } catch (ServiceResponseException clientRequestException) { Console.WriteLine(clientRequestException.HttpStatusCode); Console.WriteLine(clientRequestException.ErrorCode); Console.WriteLine(clientRequestException.ErrorMsg); } catch (ConnectionException connectionException) { Console.WriteLine(connectionException.ErrorMessage); } } } } 执行示例代码，控制台返回200即表示程序执行成功。相关参数说明请参考图像标签API。 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 200 { "result": { "tags": [ { "confidence": "98.01", "type": "树", "tag": "树", "i18n_tag": { "zh": "树", "en": "Tree" }, "i18n_type": { "zh": "树", "en": "Tree" }, "instances": [ ] } ] } } 父主题： 使用SDK（.NET）

翻拍识别示例 本章节对翻拍识别AK/SK方式使用SDK进行示例说明。 翻拍识别示例代码只需将AK/SK信息替换为实际AK/SK，代码中可以使用RunRecaptureDetectReq中的withUrl或withImage方法配置图像信息（image和url参数二选一），示例中以url为例，配置完成后运行即可。 endpoint是华为云各服务应用区域和各服务的终端节点，详情请查看地区和终端节点 。 翻拍识别调用示例代码如下： package com.huaweicloud.sdk.test; 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.image.v2.region.ImageRegion; import com.huaweicloud.sdk.image.v2.*; import com.huaweicloud.sdk.image.v2.model.*; public class RunRecaptureDetectSolution { 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); ImageClient client = ImageClient.newBuilder() .withCredential(auth) .withRegion(ImageRegion.valueOf("cn-north-4")) //此处替换为您开通服务的区域 .build(); RunRecaptureDetectRequest request = new RunRecaptureDetectRequest(); RecaptureDetectReq body = new RecaptureDetectReq(); body.withThreshold(0f); body.withUrl("https://bucketname.obs.cn-north-4.myhuaweicloud.com/image/test1.jpg"); //替换为公网可以访问的图片地址 request.withBody(body); try { RunRecaptureDetectResponse response = client.runRecaptureDetect(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.getRequestId()); System.out.println(e.getErrorCode()); System.out.println(e.getErrorMsg()); } } } 执行示例代码文件，控制台输出翻拍识别结果即表示程序执行成功。 class RunRecaptureDetectResponse { result: class RecaptureDetectResponseResult { suggestion: false category: recapture score: 0.9998 detail: [class RecaptureDetectResponseResultDetail { label: recapture confidence: 0.9998 }] } } 父主题： 使用SDK（Java）

主体识别示例 本章节对主体识别AK/SK方式使用SDK进行示例说明。 主体识别示例代码只需将AK/SK信息替换为实际AK/SK，代码中可以使用ImageMainObjectDetectionReq中的url或image方法配置图像信息（image和url参数二选一），示例中以url为例，配置完成后运行即可。 endpoint是华为云各服务应用区域和各服务的终端节点，详情请查看 地区和终端节点 。 主体识别调用示例代码如下： using System; using System.Collections.Generic; using HuaweiCloud.SDK.Core; using HuaweiCloud.SDK.Core.Auth; using HuaweiCloud.SDK.Image; using HuaweiCloud.SDK.Image.V2; using HuaweiCloud.SDK.Image.V2.Model; namespace RunImageMainObjectDetectionSolution { class Program { static void Main(string[] args) { //认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全 //本示例以ak和sk保存在环境变量中来实现身份验证为例，运行本示例前请先在本地环境中设置环境变量HUAWEICLOUD_SDK_AK和HUAWEICLOUD_SDK_SK string accessKey= Environment.GetEnvironmentVariable("HUAWEICLOUD_SDK_AK", EnvironmentVariableTarget.Machine); string secretKey= Environment.GetEnvironmentVariable("HUAWEICLOUD_SDK_SK", EnvironmentVariableTarget.Machine); var config = HttpConfig.GetDefaultConfig(); config.IgnoreSslVerification = true; var auth = new BasicCredentials(ak, sk); var client = ImageClient.NewBuilder() .WithCredential(auth) .WithRegion(ImageRegion.ValueOf("cn-north-4")) //此处替换为您开通服务的区域 .WithHttpConfig(config) .Build(); var req = new RunImageMainObjectDetectionRequest { }; req.Body = new ImageMainObjectDetectionReq() { Threshold = 30, Url = "https://XXX.jpg" //替换为公网可以访问的图片地址 }; try { var resp = client.RunImageMainObjectDetection(req); var respStatusCode = resp.HttpStatusCode; Console.WriteLine(respStatusCode); } catch (RequestTimeoutException requestTimeoutException) { Console.WriteLine(requestTimeoutException.ErrorMessage); } catch (ServiceResponseException clientRequestException) { Console.WriteLine(clientRequestException.HttpStatusCode); Console.WriteLine(clientRequestException.ErrorCode); Console.WriteLine(clientRequestException.ErrorMsg); } catch (ConnectionException connectionException) { Console.WriteLine(connectionException.ErrorMessage); } } } } 执行示例代码文件，控制台输出主体识别结果即表示程序执行成功。相关参数说明请参考主体识别API。 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 { "result": [{ "confidence": "95.73", "label": "bounding_box", "location": { "height": 327.77, "top_left_x": 3.7, "top_left_y": 1.72, "width": 463.03}}, { "confidence": "88.35", "label": "main_object_box", "location": { "height": 328.35, "top_left_x": 3.22, "top_left_y": 1.5, "width": 456.63} }] } 父主题： 使用SDK（.NET）

图像标签示例 本章节对图像标签AK/SK方式使用SDK进行示例说明。 图像标签示例代码只需将AK/SK信息替换为实际AK/SK，代码中可以使用ImageTaggingReq中的withUrl或withImage方法配置图像信息（image和url参数二选一），示例中以url为例配置完成后运行即可。 endpoint是华为云各服务应用区域和各服务的终端节点，详情请查看地区和终端节点 。 图像标签调用示例代码如下： package com.huaweicloud.sdk.test; 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.image.v2.region.ImageRegion; import com.huaweicloud.sdk.image.v2.*; import com.huaweicloud.sdk.image.v2.model.*; public class RunImageTaggingSolution { 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); ImageClient client = ImageClient.newBuilder() .withCredential(auth) .withRegion(ImageRegion.valueOf("XXXX")) //此处替换为您开通服务的区域 .build(); RunImageTaggingRequest request = new RunImageTaggingRequest(); ImageTaggingReq body = new ImageTaggingReq(); body.withLimit(50); body.withThreshold(95f); body.withLanguage("zh"); body.withUrl("https://XXX.jpg"); //此处替换为公网可以访问的图片地址 request.withBody(body); try { RunImageTaggingResponse response = client.runImageTagging(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()); } } } 执行示例代码，控制台返回200即表示程序执行成功。相关参数说明请参考图像标签API。 class RunImageTaggingResponse { result: class ImageTaggingResponseResult { tags: [class ImageTaggingItemBody { confidence: 98.00 type: 树 tag: 树 i18nTag: class ImageTaggingItemBodyI18nTag { zh: 树 en: Tree } i18nType: class ImageTaggingItemBodyI18nType { zh: 树 en: Tree } instances: [] }] } } Process finished with exit code 0 父主题： 使用SDK（Java）

媒资图像标签示例 本章节对媒资图像标签AK/SK方式使用SDK进行示例说明。 媒资图像标签示例代码只需将AK/SK信息替换为实际AK/SK，代码中可以使用ImageMediaTaggingReq中的url或image方法配置图像信息（image和url参数二选一），示例中以url为例，配置完成后运行即可。 endpoint是华为云各服务应用区域和各服务的终端节点，详情请查看 地区和终端节点 。 媒资图像标签调用示例代码如下： using System; using System.Collections.Generic; using HuaweiCloud.SDK.Core; using HuaweiCloud.SDK.Core.Auth; using HuaweiCloud.SDK.Image; using HuaweiCloud.SDK.Image.V2; using HuaweiCloud.SDK.Image.V2.Model; namespace RunImageMediaTaggingSolution { class Program { static void Main(string[] args) { //认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全 //本示例以ak和sk保存在环境变量中来实现身份验证为例，运行本示例前请先在本地环境中设置环境变量HUAWEICLOUD_SDK_AK和HUAWEICLOUD_SDK_SK string accessKey= Environment.GetEnvironmentVariable("HUAWEICLOUD_SDK_AK", EnvironmentVariableTarget.Machine); string secretKey= Environment.GetEnvironmentVariable("HUAWEICLOUD_SDK_SK", EnvironmentVariableTarget.Machine); var config = HttpConfig.GetDefaultConfig(); config.IgnoreSslVerification = true; var auth = new BasicCredentials(ak, sk); var client = ImageClient.NewBuilder() .WithCredential(auth) .WithRegion(ImageRegion.ValueOf("cn-north-4")) //此处替换为您开通服务的区域 .WithHttpConfig(config) .Build(); var req = new RunImageMediaTaggingRequest { }; req.Body = new ImageMediaTaggingReq() { Threshold = 10, Language = "zh", Url = "https://XXX.jpg" //此处替换为公网可以访问的图片地址 }; try { var resp = client.RunImageMediaTagging(req); var respStatusCode = resp.HttpStatusCode; Console.WriteLine(respStatusCode); Console.WriteLine(JsonConvert.DeserializeObject(resp.HttpBody)); } catch (RequestTimeoutException requestTimeoutException) { Console.WriteLine(requestTimeoutException.ErrorMessage); } catch (ServiceResponseException clientRequestException) { Console.WriteLine(clientRequestException.HttpStatusCode); Console.WriteLine(clientRequestException.ErrorCode); Console.WriteLine(clientRequestException.ErrorMsg); } catch (ConnectionException connectionException) { Console.WriteLine(connectionException.ErrorMessage); } } } } 执行示例代码文件，控制台输出媒资图像标签结果即表示程序执行成功。相关参数说明请参考媒资图像标签API。 200 {"result": {"tags": [{"confidence": "83.15", "type": "社会", "tag": "火灾", "i18n_tag": {"zh": "火灾", "en": "Fire"}, "i18n_type": {"zh": "社会", "en": "Society"}, "instances": []}, {"confidence": "70.21", "type": "其他", "tag": "火", "i18n_tag": {"zh": "火", "en": "Fire"}, "i18n_type": {"zh": "其他", "en": "Other"}, "instances": []}, {"confidence": "53.63", "type": "学科科学", "tag": "火球", "i18n_tag": {"zh": "火球", "en": "Fireball"}, "i18n_type": {"zh": "学科科学", "en": "Subject science"}, "instances": []}, {"confidence": "53.45", "type": "其他", "tag": "营火", "i18n_tag": {"zh": "营火", "en": "Campfire"}, "i18n_type": {"zh": "其他", "en": "Other"}, "instances": []}, {"confidence": "50.73", "type": "人工场景", "tag": "林业局", "i18n_tag": {"zh": "林业局", "en": "Forestry bureau"}, "i18n_type": {"zh": "人工场景", "en": "Manual scenario"}, "instances": []}, {"confidence": "50.34", "type": "其他", "tag": "烧毁的", "i18n_tag": {"zh": "烧毁的", "en": "Burned"}, "i18n_type": {"zh": "其他", "en": "Other"}, "instances": []}, {"confidence": "46.63", "type": "场景", "tag": "火焰", "i18n_tag": {"zh": "火焰", "en": "Flame"}, "i18n_type": {"zh": "场景", "en": "Scene"}, "instances": []}, {"confidence": "45.27", "type": "其他", "tag": "燃烧", "i18n_tag": {"zh": "燃烧", "en": "Burning"}, "i18n_type": {"zh": "其他", "en": "Other"}, "instances": []}, {"confidence": "41.32", "type": "职业/角色", "tag": "消防员", "i18n_tag": {"zh": "消防员", "en": "Fireman"}, "i18n_type": {"zh": "职业/角色", "en": "Career/Role"}, "instances": []}, {"confidence": "39.97", "type": "动作", "tag": "烧香", "i18n_tag": {"zh": "烧香", "en": "Incense burning"}, "i18n_type": {"zh": "动作", "en": "Action"}, "instances": []}]}} 父主题： 使用SDK（.NET）

主体识别示例 本章节对主体识别AK/SK方式使用SDK进行示例说明。 主体识别示例代码只需将AK/SK信息替换为实际AK/SK，代码中可以使用ImageMainObjectDetectionReq中的withUrl或withImage方法配置图像信息（image和url参数二选一），示例中以url为例，配置完成后运行即可。 endpoint是华为云各服务应用区域和各服务的终端节点，详情请查看地区和终端节点 。 主体识别调用示例代码如下： package com.huaweicloud.sdk.test; 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.image.v2.region.ImageRegion; import com.huaweicloud.sdk.image.v2.*; import com.huaweicloud.sdk.image.v2.model.*; public class RunImageMainObjectDetectionSolution { 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); ImageClient client = ImageClient.newBuilder() .withCredential(auth) .withRegion(ImageRegion.valueOf("cn-north-4")) //此处替换为您开通服务的区域 .build(); RunImageMainObjectDetectionRequest request = new RunImageMainObjectDetectionRequest(); ImageMainObjectDetectionReq body = new ImageMainObjectDetectionReq(); body.withThreshold(30f); body.withUrl("https://XXX.jpg"); //替换为公网可以访问的图片地址 request.withBody(body); try { RunImageMainObjectDetectionResponse response = client.runImageMainObjectDetection(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()); } } } 执行示例代码文件，控制台输出主体识别结果即表示程序执行成功。相关参数说明请参考主体识别API。 RunImageMainObjectDetectionResponse { result: [class ImageMainObjectDetectionInstance { label: bounding_box location: {height=327.77, top_left_x=3.7, top_left_y=1.72, width=463.03} confidence: 95.73 }, class ImageMainObjectDetectionInstance { label: main_object_box location: {height=328.35, top_left_x=3.22, top_left_y=1.5, width=456.63} confidence: 88.35 }] } 父主题： 使用SDK（Java）

翻拍识别示例 本章节对翻拍识别AK/SK方式使用SDK进行示例说明。 翻拍识别示例代码只需将AK/SK信息替换为实际AK/SK，代码中可以使用初始化RunRecaptureDetectReq中的Image或Url配置图像信息（image和url参数二选一），示例中以url为例，配置完成后运行即可。 endpoint是华为云各服务应用区域和各服务的终端节点，详情请查看地区和终端节点 。 翻拍识别调用示例代码如下： package main import ( "fmt" "github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/basic" image "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/image/v2" "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/image/v2/model" region "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/image/v2/region" ) func main() { // 认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全； // 本示例以ak和sk保存在环境变量中来实现身份验证为例，运行本示例前请先在本地环境中设置环境变量HUAWEICLOUD_SDK_AK和HUAWEICLOUD_SDK_SK。 ak := os.Getenv("HUAWEICLOUD_SDK_AK") sk := os.Getenv("HUAWEICLOUD_SDK_SK") auth := basic.NewCredentialsBuilder(). WithAk(ak). WithSk(sk). Build() client := image.NewImageClient( image.ImageClientBuilder(). WithRegion(region.ValueOf("cn-north-4")). //此处替换为您开通服务的区域 WithCredential(auth). Build()) request := &model.RunRecaptureDetectRequest{} thresholdRecaptureDetectReq:= float32(0) urlRecaptureDetectReq:= "https://bucketname.obs.cn-north-4.myhuaweicloud.com/image/test1.jpg"//替换为公网可以访问的图片地址 request.Body = &model.RecaptureDetectReq{ Threshold: &thresholdRecaptureDetectReq, Url: &urlRecaptureDetectReq, } response, err := client.RunRecaptureDetect(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 识别结果输出到控制台表示执行成功。 {"result":{"suggestion":"false","category":"recapture","score":"0.9998","detail":[{"label":"recapture","confidence":"0.9998"}]}} 父主题： 使用SDK（GO）

图像标签示例 本章节对图像标签AK/SK方式使用SDK进行示例说明。 图像标签示例代码只需将AK/SK信息替换为实际AK/SK，代码中可以使用初始化ImageTaggingReq中的url或image配置图像信息（image和url参数二选一），示例中以url为例，配置完成后运行即可。 endpoint是华为云各服务应用区域和各服务的终端节点，详情请查看地区和终端节点 。 图像标签调用示例代码如下： 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 # coding: utf-8 from huaweicloudsdkcore.auth.credentials import BasicCredentials from huaweicloudsdkcore.exceptions import exceptions from huaweicloudsdkcore.http.http_config import HttpConfig from huaweicloudsdkimage.v2 import ImageClient,RunImageTaggingRequest,ImageTaggingReq from huaweicloudsdkimage.v2.region.image_region import ImageRegion if __name__ == "__main__": # 认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全； # 本示例以ak和sk保存在环境变量中来实现身份验证为例，运行本示例前请先在本地环境中设置环境变量HUAWEICLOUD_SDK_AK和HUAWEICLOUD_SDK_SK。 ak = os.getenv("HUAWEICLOUD_SDK_AK") sk = os.getenv("HUAWEICLOUD_SDK_SK") credentials = BasicCredentials(ak, sk) client = ImageClient.new_builder() \ .with_credentials(credentials) \ .with_region(ImageRegion.value_of("cn-north-1")) \ //此处替换为您开通服务的区域 .build() try: request = RunImageTaggingRequest() request.body = ImageTaggingReq( limit=50, threshold=95, language="zh", url="https://XXX.jpg" //此处替换为公网可以访问的图片地址 ) response = client.run_image_tagging(request) print(response.status_code) print(response) except exceptions.ClientRequestException as e: print(e.status_code) print(e.request_id) print(e.error_code) print(e.error_msg) 执行示例代码，控制台返回200即表示程序执行成功。相关参数说明请参考图像标签API。 1 2 3 200 {"result": {"tags": [{"confidence": "98.00", "type": "树", "tag": "树", "i18n_tag": {"zh": "树", "en": "Tree"}, "i18n_type": {"zh": "树", "en": "Tree"}, "instances": []}]}} Process finished with exit code 0 父主题： 使用SDK（Python）

图像标签示例 本章节对图像标签AK/SK方式使用SDK进行示例说明。 图像标签示例代码只需将AK/SK信息替换为实际AK/SK，代码中可以使用初始化ImageTaggingReq中的Image或Url配置图像信息（image和url参数二选一），示例中以url为例，配置完成后运行即可。 endpoint是华为云各服务应用区域和各服务的终端节点，详情请查看地区和终端节点 。 图像标签调用示例代码如下： 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 package main import ( "fmt" "github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/basic" image "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/image/v2" "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/image/v2/model" region "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/image/v2/region" ) func main() { // 认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全； // 本示例以ak和sk保存在环境变量中来实现身份验证为例，运行本示例前请先在本地环境中设置环境变量HUAWEICLOUD_SDK_AK和HUAWEICLOUD_SDK_SK。 ak := os.Getenv("HUAWEICLOUD_SDK_AK") sk := os.Getenv("HUAWEICLOUD_SDK_SK") auth := basic.NewCredentialsBuilder(). WithAk(ak). WithSk(sk). Build() client := image.NewImageClient( image.ImageClientBuilder(). WithRegion(region.ValueOf("cn-north-1")). //此处替换为您开通服务的区域 WithCredential(auth). Build()) request := &model.RunImageTaggingRequest{} limitImageTaggingReq:= int32(50) thresholdImageTaggingReq:= float32(95) languageImageTaggingReq:= "zh" urlImageTaggingReq:= "https://XXX.jpg" //此处替换为公网可以访问的图片地址 request.Body = &model.ImageTaggingReq{ Limit: &limitImageTaggingReq, Threshold: &thresholdImageTaggingReq, Language: &languageImageTaggingReq, Url: &urlImageTaggingReq, } response, err := client.RunImageTagging(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) }} 识别结果输出到控制台表示执行成功。相关参数说明请参考图像标签API。 1 2 RunImageTaggingResponse {"result": {"tags": [{"confidence": "98.01", "type": "树", "tag": "树", "i18n_tag": {"zh": "树", "en": "Tree"}, "i18n_type": {"zh": "树", "en": "Tree"}, "instances": []}]}} Process exiting with code: 0 父主题： 使用SDK（GO）

名人识别示例 本章节对名人识别AK/SK方式使用SDK进行示例说明。 名人识别示例代码只需将AK/SK信息替换为实际AK/SK，代码中可以使用CelebrityRecognitionReq中的url或image方法配置图像信息（image和url参数二选一），示例中以url为例，配置完成后运行即可。 endpoint是华为云各服务应用区域和各服务的终端节点，详情请查看 地区和终端节点 。 名人识别调用示例代码如下： using System; using System.Collections.Generic; using HuaweiCloud.SDK.Core; using HuaweiCloud.SDK.Core.Auth; using HuaweiCloud.SDK.Image; using HuaweiCloud.SDK.Image.V2; using HuaweiCloud.SDK.Image.V2.Model; using Newtonsoft.Json; namespace RunCelebrityRecognitionSolution { class Program { static void Main(string[] args){ //认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全 //本示例以ak和sk保存在环境变量中来实现身份验证为例，运行本示例前请先在本地环境中设置环境变量HUAWEICLOUD_SDK_AK和HUAWEICLOUD_SDK_SK string accessKey= Environment.GetEnvironmentVariable("HUAWEICLOUD_SDK_AK", EnvironmentVariableTarget.Machine); string secretKey= Environment.GetEnvironmentVariable("HUAWEICLOUD_SDK_SK", EnvironmentVariableTarget.Machine); var config = HttpConfig.GetDefaultConfig(); config.IgnoreSslVerification = true; var auth = new BasicCredentials(ak, sk); var client = ImageClient.NewBuilder() .WithCredential(auth) .WithRegion(ImageRegion.ValueOf("cn-north-1")) //此处替换为您开通服务的区域 .WithHttpConfig(config) .Build(); var req = new RunCelebrityRecognitionRequest { }; req.Body = new CelebrityRecognitionReq() { Threshold = 0.48, Url = "https://XXX.jpg" //此处替换为公网可以访问的图片地址 }; try { var resp = client.RunCelebrityRecognition(req); var respStatusCode = resp.HttpStatusCode; Console.WriteLine(respStatusCode); Console.WriteLine(JsonConvert.DeserializeObject(resp.HttpBody)); } catch (RequestTimeoutException requestTimeoutException) { Console.WriteLine(requestTimeoutException.ErrorMessage); } catch (ServiceResponseException clientRequestException) { Console.WriteLine(clientRequestException.HttpStatusCode); Console.WriteLine(clientRequestException.ErrorCode); Console.WriteLine(clientRequestException.ErrorMsg); } catch (ConnectionException connectionException) { Console.WriteLine(connectionException.ErrorMessage); } } } } 执行示例代码文件，控制台输出名人识别结果即表示程序执行成功。相关参数说明请参考名人识别API。 1 2 3 4 5 6 7 8 9 10 11 12 13 200 { 'result': [{ 'confidence': 0.9990678852332598, 'face_detail': { 'h': 510, 'w': 357, 'x': 260, 'y': 201 }, 'label': '迈克尔·杰克逊' }] } 父主题： 使用SDK（.NET）

翻拍识别示例 本章节对翻拍识别AK/SK方式使用SDK进行示例说明。 翻拍识别示例代码只需将AK/SK信息替换为实际AK/SK，代码中可以使用RunRecaptureDetectReq中的url或image方法配置图像信息（image和url参数二选一），示例中以url为例，配置完成后运行即可。 endpoint是华为云各服务应用区域和各服务的终端节点，详情请查看 地区和终端节点 。 翻拍识别调用示例代码如下： using System; using System.Collections.Generic; using HuaweiCloud.SDK.Core; using HuaweiCloud.SDK.Core.Auth; using HuaweiCloud.SDK.Image; using HuaweiCloud.SDK.Image.V2; using HuaweiCloud.SDK.Image.V2.Model; namespace RunRecaptureDetectSolution { class Program { static void Main(string[] args) { //认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全 //本示例以ak和sk保存在环境变量中来实现身份验证为例，运行本示例前请先在本地环境中设置环境变量HUAWEICLOUD_SDK_AK和HUAWEICLOUD_SDK_SK string accessKey= Environment.GetEnvironmentVariable("HUAWEICLOUD_SDK_AK", EnvironmentVariableTarget.Machine); string secretKey= Environment.GetEnvironmentVariable("HUAWEICLOUD_SDK_SK", EnvironmentVariableTarget.Machine); var config = HttpConfig.GetDefaultConfig(); config.IgnoreSslVerification = true; var auth = new BasicCredentials(ak, sk); var client = ImageClient.NewBuilder() .WithCredential(auth) .WithRegion(ImageRegion.ValueOf("cn-north-4")) //此处替换为您开通服务的区域 .WithHttpConfig(config) .Build(); var req = new RunRecaptureDetectRequest { }; req.Body = new RecaptureDetectReq() { Threshold = 0, Url = "https://bucketname.obs.cn-north-4.myhuaweicloud.com/image/test1.jpg"//替换为公网可以访问的图片地址 }; try { var resp = client.RunRecaptureDetect(req); var respStatusCode = resp.HttpStatusCode; Console.WriteLine(respStatusCode); Console.WriteLine(resp.HttpBody); } catch (RequestTimeoutException requestTimeoutException) { Console.WriteLine(requestTimeoutException.ErrorMessage); } catch (ServiceResponseException clientRequestException) { Console.WriteLine(clientRequestException.HttpStatusCode); Console.WriteLine(clientRequestException.RequestId); Console.WriteLine(clientRequestException.ErrorCode); Console.WriteLine(clientRequestException.ErrorMsg); } catch (ConnectionException connectionException) { Console.WriteLine(connectionException.ErrorMessage); } } } } 执行示例代码文件，控制台输出翻拍识别结果即表示程序执行成功。 200 {"result":{"suggestion":"false","category":"recapture","score":"0.9998","detail":[{"label":"recapture","confidence":"0.9998"}]}} 父主题： 使用SDK（.NET）

媒资图像标签示例 本章节对媒资图像标签AK/SK方式使用SDK进行示例说明。 媒资图像标签示例代码只需将AK/SK信息替换为实际AK/SK，代码中可以使用ImageMediaTaggingReq中的Url或Image方法配置图像信息（image和url参数二选一），示例中以url为例，配置完成后运行即可。 endpoint是华为云各服务应用区域和各服务的终端节点，详情请查看地区和终端节点 。 媒资图像标签调用示例代码如下： package main import ( "fmt" "github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/basic" image "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/image/v2" "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/image/v2/model" region "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/image/v2/region" ) func main() { // 认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全； // 本示例以ak和sk保存在环境变量中来实现身份验证为例，运行本示例前请先在本地环境中设置环境变量HUAWEICLOUD_SDK_AK和HUAWEICLOUD_SDK_SK。 ak := os.Getenv("HUAWEICLOUD_SDK_AK") sk := os.Getenv("HUAWEICLOUD_SDK_SK") auth := basic.NewCredentialsBuilder(). WithAk(ak). WithSk(sk). Build() client := image.NewImageClient( image.ImageClientBuilder(). WithRegion(region.ValueOf("cn-north-4")). //此处替换为您开通服务的区域 WithCredential(auth). Build()) request := &model.RunImageMediaTaggingRequest{} thresholdImageMediaTaggingReq:= float32(10) languageImageMediaTaggingReq:= "zh" urlImageMediaTaggingReq:= "https://XXX.jpg" //此处替换为公网可以访问的图片地址 request.Body = &model.ImageMediaTaggingReq{ Threshold: &thresholdImageMediaTaggingReq, Language: &languageImageMediaTaggingReq, Url: &urlImageMediaTaggingReq, } response, err := client.RunImageMediaTagging(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 执行示例代码文件，控制台输出媒资图像标签结果即表示程序执行成功。相关参数说明请参考媒资图像标签API。 RunImageMediaTaggingResponse {"result": {"tags": [{"confidence": "83.15", "type": "社会", "tag": "火灾", "i18n_tag": {"zh": "火灾", "en": "Fire"}, "i18n_type": {"zh": "社会", "en": "Society"}, "instances": []}, {"confidence": "70.21", "type": "其他", "tag": "火", "i18n_tag": {"zh": "火", "en": "Fire"}, "i18n_type": {"zh": "其他", "en": "Other"}, "instances": []}, {"confidence": "53.63", "type": "学科科学", "tag": "火球", "i18n_tag": {"zh": "火球", "en": "Fireball"}, "i18n_type": {"zh": "学科科学", "en": "Subject science"}, "instances": []}, {"confidence": "53.45", "type": "其他", "tag": "营火", "i18n_tag": {"zh": "营火", "en": "Campfire"}, "i18n_type": {"zh": "其他", "en": "Other"}, "instances": []}, {"confidence": "50.73", "type": "人工场景", "tag": "林业局", "i18n_tag": {"zh": "林业局", "en": "Forestry bureau"}, "i18n_type": {"zh": "人工场景", "en": "Manual scenario"}, "instances": []}, {"confidence": "50.34", "type": "其他", "tag": "烧毁的", "i18n_tag": {"zh": "烧毁的", "en": "Burned"}, "i18n_type": {"zh": "其他", "en": "Other"}, "instances": []}, {"confidence": "46.63", "type": "场景", "tag": "火焰", "i18n_tag": {"zh": "火焰", "en": "Flame"}, "i18n_type": {"zh": "场景", "en": "Scene"}, "instances": []}, {"confidence": "45.27", "type": "其他", "tag": "燃烧", "i18n_tag": {"zh": "燃烧", "en": "Burning"}, "i18n_type": {"zh": "其他", "en": "Other"}, "instances": []}, {"confidence": "41.32", "type": "职业/角色", "tag": "消防员", "i18n_tag": {"zh": "消防员", "en": "Fireman"}, "i18n_type": {"zh": "职业/角色", "en": "Career/Role"}, "instances": []}, {"confidence": "39.97", "type": "动作", "tag": "烧香", "i18n_tag": {"zh": "烧香", "en": "Incense burning"}, "i18n_type": {"zh": "动作", "en": "Action"}, "instances": []}]}} 父主题： 使用SDK（GO）

主体识别示例 本章节对主体识别AK/SK方式使用SDK进行示例说明。 主体识别示例代码只需将AK/SK信息替换为实际AK/SK，代码中可以使用初始化ImageMainObjectDetectionReq中的url或image配置图像信息（image和url参数二选一），示例中以url为例，配置完成后运行即可。 endpoint是华为云各服务应用区域和各服务的终端节点，详情请查看地区和终端节点 。 主体识别调用示例代码如下： 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 # coding: utf-8 from huaweicloudsdkcore.auth.credentials import BasicCredentials from huaweicloudsdkimage.v2.region.image_region import ImageRegion from huaweicloudsdkcore.exceptions import exceptions from huaweicloudsdkimage.v2 import * if __name__ == "__main__": # 认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全； # 本示例以ak和sk保存在环境变量中来实现身份验证为例，运行本示例前请先在本地环境中设置环境变量HUAWEICLOUD_SDK_AK和HUAWEICLOUD_SDK_SK。 ak = os.getenv("HUAWEICLOUD_SDK_AK") sk = os.getenv("HUAWEICLOUD_SDK_SK") credentials = BasicCredentials(ak, sk) \ client = ImageClient.new_builder() \ .with_credentials(credentials) \ .with_region(ImageRegion.value_of("cn-north-4")) \ //此处替换为您开通服务的区域 .build() try: request = RunImageMainObjectDetectionRequest() request.body = ImageMainObjectDetectionReq( threshold=30, url="https://XXX.jpg" //替换为公网可以访问的图片地址 ) response = client.run_image_main_object_detection(request) print(response) except exceptions.ClientRequestException as e: print(e.status_code) print(e.request_id) print(e.error_code) print(e.error_msg) 执行示例代码文件，控制台输出主体识别结果即表示程序执行成功。相关参数说明请参考主体识别API。 1 2 3 4 5 6 7 8 { "result": [{ "label": "bounding_box", "location": {"height": 327.77, "top_left_x": 3.7, "top_left_y": 1.72, "width": 463.03}, "confidence": "95.73"}, {"label": "main_object_box", "location": {"height": 328.35, "top_left_x": 3.22, "top_left_y": 1.5, "width": 456.63}, "confidence": "88.35"}] } 父主题： 使用SDK（Python）

媒资图像标签示例 本章节对媒资图像标签AK/SK方式使用SDK进行示例说明。 媒资图像标签示例代码只需将AK/SK信息替换为实际AK/SK，代码中可以使用ImageMediaTaggingReq中的withUrl或withImage方法配置图像信息（image和url参数二选一），示例中以url为例，配置完成后运行即可。 endpoint是华为云各服务应用区域和各服务的终端节点，详情请查看地区和终端节点 。 媒资图像标签调用示例代码如下： package com.huaweicloud.sdk.test; 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.image.v2.region.ImageRegion; import com.huaweicloud.sdk.image.v2.*; import com.huaweicloud.sdk.image.v2.model.*; public class RunImageMediaTaggingSolution { 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); ImageClient client = ImageClient.newBuilder() .withCredential(auth) .withRegion(ImageRegion.valueOf("cn-north-4")) //此处替换为您开通服务的区域 .build(); RunImageMediaTaggingRequest request = new RunImageMediaTaggingRequest(); ImageMediaTaggingReq body = new ImageMediaTaggingReq(); body.withThreshold(10f); body.withLanguage("zh"); body.withUrl("https://XXX.jpg"); //此处替换为公网可以访问的图片地址 request.withBody(body); try { RunImageMediaTaggingResponse response = client.runImageMediaTagging(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()); } } } 执行示例代码文件，控制台输出媒资图像标签结果即表示程序执行成功。相关参数说明请参考媒资图像标签API。 class RunImageMediaTaggingResponse { result: class ImageMediaTaggingResponseResult { tags: [class ImageMediaTaggingItemBody { confidence: 83.15 type: 社会 tag: 火灾 i18nTag: class ImageMediaTaggingItemBodyI18nTag { zh: 火灾 en: Fire } i18nType: class ImageMediaTaggingItemBodyI18nType { zh: 社会 en: Society } instances: [] }, class ImageMediaTaggingItemBody { confidence: 70.21 type: 其他 tag: 火 i18nTag: class ImageMediaTaggingItemBodyI18nTag { zh: 火 en: Fire } i18nType: class ImageMediaTaggingItemBodyI18nType { zh: 其他 en: Other } instances: [] }, class ImageMediaTaggingItemBody { confidence: 53.63 type: 学科科学 tag: 火球 i18nTag: class ImageMediaTaggingItemBodyI18nTag { zh: 火球 en: Fireball } i18nType: class ImageMediaTaggingItemBodyI18nType { zh: 学科科学 en: Subject science } instances: [] }, class ImageMediaTaggingItemBody { confidence: 53.45 type: 其他 tag: 营火 i18nTag: class ImageMediaTaggingItemBodyI18nTag { zh: 营火 en: Campfire } i18nType: class ImageMediaTaggingItemBodyI18nType { zh: 其他 en: Other } instances: [] }, class ImageMediaTaggingItemBody { confidence: 50.73 type: 人工场景 tag: 林业局 i18nTag: class ImageMediaTaggingItemBodyI18nTag { zh: 林业局 en: Forestry bureau } i18nType: class ImageMediaTaggingItemBodyI18nType { zh: 人工场景 en: Manual scenario } instances: [] }, class ImageMediaTaggingItemBody { confidence: 50.34 type: 其他 tag: 烧毁的 i18nTag: class ImageMediaTaggingItemBodyI18nTag { zh: 烧毁的 en: Burned } i18nType: class ImageMediaTaggingItemBodyI18nType { zh: 其他 en: Other } instances: [] }, class ImageMediaTaggingItemBody { confidence: 46.63 type: 场景 tag: 火焰 i18nTag: class ImageMediaTaggingItemBodyI18nTag { zh: 火焰 en: Flame } i18nType: class ImageMediaTaggingItemBodyI18nType { zh: 场景 en: Scene } instances: [] }, class ImageMediaTaggingItemBody { confidence: 45.27 type: 其他 tag: 燃烧 i18nTag: class ImageMediaTaggingItemBodyI18nTag { zh: 燃烧 en: Burning } i18nType: class ImageMediaTaggingItemBodyI18nType { zh: 其他 en: Other } instances: [] }, class ImageMediaTaggingItemBody { confidence: 41.32 type: 职业/角色 tag: 消防员 i18nTag: class ImageMediaTaggingItemBodyI18nTag { zh: 消防员 en: Fireman } i18nType: class ImageMediaTaggingItemBodyI18nType { zh: 职业/角色 en: Career/Role } instances: [] }, class ImageMediaTaggingItemBody { confidence: 39.97 type: 动作 tag: 烧香 i18nTag: class ImageMediaTaggingItemBodyI18nTag { zh: 烧香 en: Incense burning } i18nType: class ImageMediaTaggingItemBodyI18nType { zh: 动作 en: Action } instances: [] }] } } 父主题： 使用SDK（Java）

名人识别示例 本章节对名人识别AK/SK方式使用SDK进行示例说明。 名人识别示例代码只需将AK/SK信息替换为实际AK/SK，代码中可以使用初始化CelebrityRecognitionReq中的url或image配置图像信息（image和url参数二选一），示例中以url为例，配置完成后运行即可。 endpoint是华为云各服务应用区域和各服务的终端节点，详情请查看地区和终端节点 。 名人识别调用示例代码如下： 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 # coding: utf-8 from huaweicloudsdkcore.auth.credentials import BasicCredentials from huaweicloudsdkcore.exceptions import exceptions from huaweicloudsdkcore.http.http_config import HttpConfig from huaweicloudsdkimage.v2 import ImageClient,RunCelebrityRecognitionRequest,CelebrityRecognitionReq from huaweicloudsdkimage.v2.region.image_region import ImageRegion if __name__ == "__main__": # 认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全； # 本示例以ak和sk保存在环境变量中来实现身份验证为例，运行本示例前请先在本地环境中设置环境变量HUAWEICLOUD_SDK_AK和HUAWEICLOUD_SDK_SK。 ak = os.getenv("HUAWEICLOUD_SDK_AK") sk = os.getenv("HUAWEICLOUD_SDK_SK") credentials = BasicCredentials(ak, sk) client = ImageClient.new_builder() \ .with_credentials(credentials) \ .with_region(ImageRegion.value_of("cn-north-1")) \ //此处替换为您开通服务的区域 .build() try: request = RunCelebrityRecognitionRequest() request.body = CelebrityRecognitionReq( threshold=0, url="https://XXX.jpg" //此处替换为公网可以访问的图片地址 ) response = client.run_celebrity_recognition(request) print(response.status_code) print(response) except exceptions.ClientRequestException as e: print(e.status_code) print(e.request_id) print(e.error_code) print(e.error_msg) 执行示例代码文件，控制台输出名人识别结果即表示程序执行成功。相关参数说明请参考名人识别API。 1 2 3 4 200 {'result': [{'confidence': 0.9990678852332598, 'face_detail': {'h': 510, 'w': 357, 'x': 260, 'y': 201}, 'label': '迈克尔·杰克逊'}]} 父主题： 使用SDK（Python）

安装SDK 推荐使用 Composer 安装 SDK 。 Composer 是 php 的依赖管理工具，允许您在项目中声明依赖关系并安装这些依赖： // 安装 Composer curl -sS https://getcomposer.org/installer | php // 安装 PHP SDK composer require huaweicloud/huaweicloud-sdk-php 安装完毕后，你需要引入 Composer 的自动加载文件： require 'path/to/vendor/autoload.php';

名人识别示例 本章节对名人识别AK/SK方式使用SDK进行示例说明。 名人识别示例代码只需将AK/SK信息替换为实际AK/SK，代码中可以使用初始化CelebrityRecognitionReq中的Image或Url配置图像信息（image和url参数二选一），示例中以url为例，配置完成后运行即可。 endpoint是华为云各服务应用区域和各服务的终端节点，详情请查看地区和终端节点 。 名人识别调用示例代码如下： 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 package main import ( "fmt" "github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/basic" image "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/image/v2" "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/image/v2/model" region "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/image/v2/region" ) func main() { // 认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全； // 本示例以ak和sk保存在环境变量中来实现身份验证为例，运行本示例前请先在本地环境中设置环境变量HUAWEICLOUD_SDK_AK和HUAWEICLOUD_SDK_SK。 ak := os.Getenv("HUAWEICLOUD_SDK_AK") sk := os.Getenv("HUAWEICLOUD_SDK_SK") auth := basic.NewCredentialsBuilder(). WithAk(ak). WithSk(sk). Build() client := image.NewImageClient( image.ImageClientBuilder(). WithRegion(region.ValueOf("cn-north-1")). //此处替换为您开通服务的区域 WithCredential(auth). Build()) request := &model.RunCelebrityRecognitionRequest{} thresholdCelebrityRecognitionReq:= float32(0.48) urlCelebrityRecognitionReq:= "https://XXX.jpg" //此处替换为公网可以访问的图片地址 request.Body = &model.CelebrityRecognitionReq{ Threshold: &thresholdCelebrityRecognitionReq, Url: &urlCelebrityRecognitionReq, } response, err := client.RunCelebrityRecognition(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 识别结果输出到控制台表示执行成功。相关参数说明请参考名人识别API。 1 2 RunCelebrityRecognitionResponse {"result":[{"confidence":0.9990679,"face_detail":{"h":510,"w":357,"x":260,"y":201},"label":"迈克尔·杰克逊"}]} Process exiting with code: 0 父主题： 使用SDK（GO）

操作步骤 登录MetaStudio控制台。 单击“分身形象制作”下方的“开始创建”，进入分身形象制作页面。 图1 定制数字人形象 上传分身数字人训练数据。 界面操作详情，如表1所示。 表1 界面操作说明 区域 参数 说明 分身数字人训练数据上传 角色名称 输入分身数字人的角色名称。 示例：云笙。 训练视频 从本地上传已录制好，且符合拍摄要求的人像视频。 录制的视频要求4K，时长建议5~6分钟，分辨率≥1080P，宽高比16:9（横屏）或9:16（竖屏），建议优先使用竖屏拍摄。支持MP4、MOV格式的视频。 背景替换 选择“抠除拍摄背景”，制作分身数字人视频时，可以替换背景。 身份认证及授权数据上传 联系方式 请输入有效的11位手机号码。 身份证照片 需要分别上传身份证人像面和国徽面的照片。 单击“点击上传人像面”，从本地选择身份证人像面照片上传。 单击“点击上传国徽面”，从本地选择身份证国徽面照片上传。 形象授权 上传形象授权书。 操作如下所示： 单击“授权书模板”，将授权书模板下载本地。 打印授权书，由身份证本人完成签署操作。 扫描文件生成pdf文件，或拍摄文件生成jpg、png格式的图片。 单击“点击上传授权书”，从本地选择pdf、jpg或png格式的授权书上传。 单击“提交制作”。 数据上传完成后，界面提示“制作任务提交成功！”，如图2所示。 图2 制作任务提交成功 用户可以单击“查看制作任务列表”，进入分身数字人定制任务列表页面，如图所示。 图3 任务列表 单击任务所在行的“查看详情”，进入“定制任务详情”页面，如图4所示。 查看分身数字人定制任务审核进展，当前状态为“系统审核中”。数字人定制任务提交成功后，会在1个工作日内完成审核。 图4 定制任务详情 审核通过后，任务状态变更为“算法训练中”，如图所示。 数字人定制任务审核通过后，启动算法训练，会在3个工作日内训练完成并生成数字人。 图5 数字人定制任务 等待数字人模型训练完成后，任务状态变更为“算法训练完成”，如图6所示。 图6 数字人定制任务 如果训练生成的数字人形象满足需求，单击右下方的“通过”。在弹出的“确认”对话框中，单击“确认”，数字人形象生成完成。

操作步骤 登录MetaStudio控制台。 单击“声音制作”下方的“开始创建”，进入声音制作页面。 图1 定制声音 在“华为模型”页签，配置声音制作参数。 界面操作详情，如表1所示。 表1 界面操作说明 区域 说明 声音制作方式 选择声音制作方式“基础版声音制作”，音频格式为WAV或MP3文件。需整段录制，每句之间有2~3秒的停顿。音频时长3~10分钟，建议5分钟。 请完善声音信息 输入声音名称，示例：欢快女声。 请选择声音性别 选择声音的性别，示例：女生。 原始输入语言 选择声音的原始输入语言，示例：中文。 选择声音标签 声音的标签。请根据所选文案样例，选择相应的标签，如下所示： 营销：营销宣传风格文案 新闻：新闻播报风格文案 请制作声音 使用“语料上传”的方式，直接上传一个已录制好的长音频WAV或MP3文件，无需压缩，无需携带文案txt文件。 声音授权 单击“授权书模板”，下载授权书模板后打印。用户手写相关信息后，重新生成签署后的pdf文件，或者拍摄成jpg或png格式的图片后上传。 授权书内容，可参考授权书。 单击“提交制作”。 弹出“资源消耗提示”对话框。提示用户目前声音制作服务剩余数量，本次将消耗1个资源。 如果用户确认无误，单击“确认提交”。 声音制作任务提交成功后，界面提示“制作任务提交成功”，如图2所示。 声音制作任务提交成功后，需要等待1天左右的时间审核。任务审核通过后，启动声音制作。 图2 制作任务提交成功 用户可以单击“查看制作任务列表”，查看声音制作任务审核进展。 当状态变更为“系统审核完成”，自动启动算法训练。如果系统存在多个算法训练任务，可能会存在排队和延迟的现象，请耐心等待。 确认声音制作任务已训练完成后，在左侧导航栏中，单击“我的创作”。 选择“声音”，找到已生成的声音，单击声音卡片中的头像，即可试听声音效果。 图3 声音

操作步骤 登录MetaStudio控制台。 单击“声音制作”下方的“开始创建”，进入声音制作页面。 界面左侧是声音制作页面，右侧为声音制作流程。声音制作录制教程，可以帮助用户快速制作声音。 图1 定制声音 在“华为模型”页签，配置声音制作参数。 界面操作详情，如表1所示。 表1 界面操作说明 区域 说明 声音制作方式 MetaStudio提供下述声音制作方式： 基础版声音制作：需整段录制生成一个WAV或MP3格式的音频文件，时长3~10分钟，建议5分钟。 进阶版声音制作：需整段录制生成一个WAV或MP3格式的音频文件，时长10~30分钟，建议15分钟。 高品质声音制作：需整段录制生成一个WAV或MP3格式的音频文件，时长1小时以上，建议1小时。 每种声音制作方式后面都会展示剩余次数，需要保证剩余次数充足。录制过程中，每句之间有2~3秒的停顿。 其中，进阶版和高品质声音制作需要更多语料，训练时长更长，声音效果更佳。 请完善声音信息 输入声音名称。 示例：欢快女声。 请选择声音性别 声音的性别，如下所示： 男生 女生 原始输入语言 声音的原始输入语言，包含如下选项： 中文 英文 选择声音标签 声音的标签，包含如下选项： 新闻 营销 针对上述标签，MetaStudio服务预置了相应的文案内容，如文案样例（基础版）、文案样例（进阶版）和文案样例（高品质）所示。如果使用预置文案，必须选对标签。 请制作声音 制作声音的方式为“语料上传”。界面提供录音指导，需要按照指导，录制生成一个符合时长要求的基础版、进阶版或高品质音频文件。WAV或MP3格式音频文件支持直接上传，无需压缩，无需携带文案txt文件。 如果未使用服务预置文案，声音标签仅作为标签，来区分声音使用场景。 声音授权 单击“授权书模板”，下载授权书模板后打印。用户手写相关信息后，重新生成签署后的pdf文件，或者拍摄成jpg或png格式的图片后上传。 授权书内容，可参考授权书。 单击“提交制作”。 弹出“资源消耗提示”对话框。提示用户目前声音制作服务剩余数量，本次将消耗1个资源。 如果用户确认无误，单击“确认提交”。 声音制作任务提交成功后，界面提示“制作任务提交成功”，如图2所示。 声音制作任务提交成功后，需要等待1天左右的时间审核。任务审核通过后，启动声音制作。 声音模型制作耗时，如下所示： 基础版：约1~3个工作日。 进阶版：约1~3个工作日。 高品质：约5个工作日。 图2 制作任务提交成功 用户可以单击“查看制作任务列表”，查看声音制作任务审核进展。 当状态变更为“系统审核完成”，自动启动算法训练。如果系统存在多个算法训练任务，可能会存在排队和延迟的现象，请耐心等待。

操作步骤 登录MetaStudio控制台。 单击“分身形象制作”下方的“开始创建”，进入分身形象制作页面。 界面左侧是定制分身数字人的数据上传界面。 界面右侧上方，展示分身数字人定制流程。下方展示训练视频拍摄指导和样例视频，包括：拍摄前准备、拍摄中操作和拍摄后处理，有效指导用户拍摄生成一段完整可用的训练视频，用于训练生成分身数字人。 图1 定制数字人形象 上传分身数字人训练数据。 界面操作详情，如表1所示。 表1 界面操作说明 区域 参数 说明 分身数字人训练数据上传 角色名称 输入分身数字人的角色名称。 示例：云笙。 训练视频 从本地上传已录制好，且符合拍摄要求的真人人像视频，训练生成数字人形象。 录制的视频要求4K，时长建议5~6分钟，分辨率≥1080P，宽高比16:9（横屏）或9:16（竖屏），建议优先使用竖屏拍摄。支持MP4、MOV格式的视频。 训练生成的分身数字人形象与真人形象完全相同。 背景替换 分身数字人是否支持更换背景。 包含如下选项，请根据实际情况选择： 抠除拍摄背景：制作分身数字人视频时，可以更换背景。 保留拍摄背景：分身数字人使用拍摄时的原背景，不支持更换背景。 身份认证及授权数据上传 联系方式 请输入有效的11位手机号码。 身份证照片 需要分别上传身份证人像面和国徽面的照片。 单击“点击上传人像面”，从本地选择身份证人像面照片上传。 单击“点击上传国徽面”，从本地选择身份证国徽面照片上传。 形象授权 上传形象授权书。 操作如下所示： 单击“授权书模板”，将授权书模板下载本地。 打印授权书，由身份证本人完成签署操作。 扫描文件生成pdf文件，或拍摄文件生成jpg、png格式的图片。 单击“点击上传授权书”，从本地选择pdf、jpg或png格式的授权书上传。 授权书内容，可参考授权书。 单击“提交制作”。 数据上传完成后，界面提示“制作任务提交成功！”，如图2所示。 数字人定制任务提交成功后，会在1个工作日内完成审核。任务审核通过后，才能进行算法训练，会在3个工作日内训练完成并生成数字人。 图2 制作任务提交成功 用户可以单击“查看制作任务列表”，进入分身数字人定制任务列表页面。 单击任务所在行的“查看详情”，进入“定制任务详情”页面。 查看分身数字人定制任务审核进展。当前状态为“系统审核中”，需要等待服务管理员审核通过后，状态变更为“待算法训练”。 如果数字人定制任务被驳回，需要查看驳回原因，并重新按照要求录制视频并上传。 操作步骤详情如下所示： 在服务主界面，单击左侧导航栏中的“任务中心”。 查看“分身数字人”页签的数字人定制任务列表，找到被驳回的数字人定制任务。 任务状态为“审核未通过”。 单击任务右侧的“查看原因”，在弹出的“审核未通过”对话框中，查看审核未通过的原因。 按照规范重新录制或提供符合规范的视频。 单击任务右侧的“重新上传”，上传更新后的视频。 数字人定制任务重新进入审核流程。

操作步骤 登录MetaStudio控制台。 在“工作台”界面，单击“分身视频制作”下方的“开始创建”。 进入视频制作界面，界面详情如视频制作界面说明-图1所示。操作说明如下所示： 视频素材区域，除了系统预置素材外，角色还可以自定义新增分身数字人，背景、PPT、贴图、视频和音乐还可以从本地导入使用。 从视频素材区域添加到画布区域中的PPT、贴图、视频和数字人支持进行图层管理，如：上移一层、下移一层、置顶、置底、应用到全局、删除等。还支持设置大小，拖动位置。 可以单击画布区域上方的图标，切换视频画面比例为横屏“16:9”或竖屏“9:16”。 Flexus分身数字人左上角会有标识。未带有标识的数字人均为标准版形象。 需注意Flexus视频制作和标准版视频制作分开计费，从各自的套餐包中扣除费用。 Flexus视频制作：必须使用Flexus形象，声音使用不受限制。 按视频制作时长计费，计费项为“Flexus分身数字人视频制作”，详见计费说明。 系统声音和Flexus声音免费使用。第三方声音的计费方式，详见购买出门问问 语音合成 套餐包。 标准版视频制作：必须使用标准版形象，声音不支持使用Flexus声音。 按视频制作时长计费，计费项为“分身数字人视频制作”，详见计费说明。 系统声音免费使用。第三方声音的计费方式，详见购买出门问问语音合成套餐包。 画布制作完成后，再制作语音。 支持下述2种方式生成语音。每个场景仅支持选择一种音频生成方式。 文本驱动 在文本输入框中，输入文本内容，以生成音频，如图1所示。 文本示例：今天是9月26日，星期二，天气晴朗，欢迎大家到访。我们精心布置了现场，室内摆放了各类植物和鲜花，场地宽敞明亮，足够大家在室内共同交流和活动。 图1 文本驱动 文本内容的操作说明如表1所示。 表1 操作说明 操作 说明 插入停顿 将鼠标放在需要停顿的文字右侧，单击“插入停顿”。在弹出的提示框中，选择“换气”或者停顿的时间，也支持自定义停顿时长。 连读 选中需要连读的文本内容，单击“连读”。 多音字 选中文本中的多音字，单击“多音字”，在弹出的提示框中，选择正确的发音或者自定义发音。 须知： 这里设置的多音字，仅对当前视频草稿有效，如需全局生效，可参考配置特殊词表配置。 别名 选中需要通过别名播报的文本内容 ，单击“别名”，设置为实际播报的内容。 须知： 这里设置的别名，仅对当前视频草稿有效，如需全局生效，可参考配置特殊词表配置。 数字英文 示例数字“1024”的读法如下所示： 数字：一零二四 数值：一千零二十四 日期：十月二十四 电话：幺零二四 示例英文“API”的读法如下所示： 字母：API 单词：api 音标 选中英文单词，输入合适的音标。 局部语速 选中需要变速播报的文本，设置局部语速。 取值范围[0.5x，2x]，含义如下所示： 0.5x：0.5倍速播报，即减速播报。 2x：2倍速播报，即加速播报。 全局语速 设置全局语速。 取值范围[0.5x，2x]，含义如下所示： 0.5x：0.5倍速播报，即减速播报。 2x：2倍速播报，即加速播报。 音色设置 单击音色名称，在弹出的声音对话框中，选择需要的声音。 无标注的系统声音，均为免费声音，可直接选用。 标注有“第三方”的声音，需要购买激活后才能使用，操作请参考购买出门问问声音套餐。 带有标识的为Flexus声音，仅支持搭配Flexus数字人使用。如果视频为标准版形象，不支持选择Flexus声音进行视频合成。 试听 单击“试听”，试听语音效果。 图标 单击图标，放大展示“文本驱动”页签，提升用户操作体验。 单击“确定”，可关闭页面。 图标 调整视频播报的音量。 图标 单击图标可开启字幕展示，并可在画布左侧设置字幕的字体、大小和位置等。 “音频驱动”方式目前仅支持中文普通话的场景开启字幕。 图标 展示当前视频的宽高比。 图标 第一次单击可折叠“文本驱动/视频驱动”，第二次单击后恢复展示。 音频驱动 需从本地上传已录制好的音频。音频文件格式需要为WAV、MP3或M4A，大小不能超过100M。 可单击“导入”上传音频，也可以直接拖拽本地音频文件至提示区域中，完成上传。单击左侧的图标，可试听音频效果。如果音频效果不佳，可以单击“导入”，覆盖更新音频。 图2 音频驱动 音频制作完成后，可单击音量图标，调整音频的音量。 上述操作全部完成后，第一个场景的视频内容已制作完成。 如果还需要制作更多场景，可单击“场景”区域的“+”图标，新增场景。制作过程参考第一个场景即可。 如果视频内容是分享PPT，可在“PPT”页签，先从本地导入PPT，再插入需要分享的PPT页，详情请参见PPT。每页PPT会对应生成一个场景，依次设置完成所有场景即可。 所有场景设置完成后，单击界面右上角的“合成视频”，弹出“合成设置”对话框。 参数设置说明如下所示： 分辨率：根据实际情况，选择视频的分辨率。 导出为：输入导出文件的名称。 画质增强：开启后将提升视频清晰度，合成时间相应变长。请根据实际情况确定是否开启。 单击“确定”，弹出“视频制作任务中心”对话框。 可查看视频合成任务的进度，直至合成成功。 单击“合成成功”状态右侧的图标，进入视频详情页面，如图3所示。 单击“预览”，可以看到合成的视频。预览过程中，可全屏播放，或下载视频到本地。 图3 视频详情 如果用户对合成的视频不满意，可以参考下述步骤，进行二次制作，重新合成。 在左侧导航栏中，选择“工作台”。 在“最近项目”区域，选择“视频项目”页签后，右侧页签选择“视频草稿”，查看视频草稿列表，如图4所示。 图4 视频项目 将鼠标移至卡片的文字描述区域，单击“编辑视频”，如图5所示。 进入 视频编辑 界面，更新视频内容，重新合成视频。 图5 我的视频

相关操作 怎样设置作业的参数？ 在FLink作业列表中选择待编辑的作业。 单击操作列“编辑”。 在参数区域输入参数信息。 指定类的参数列表，参数之间使用空格分隔。 参数输入格式：--key1 value1 --key2 value2 例如：控制台入输入的参数 --bootstrap.server 192.168.168.xxx:9092 通过ParameterTool解析后的参数如下所示： 图5 解析后的参数 怎样查看作业日志？ 在FLink作业列表中单击作业名称，进入作业详情页面。 单击“运行日志”，即可在控制台查看作业日志。 此处只展示最新的运行日志，更多信息请查看保存日志的OBS桶。

环境准备 登录 MRS 管理控制台，创建MRS集群，选择“开启kerberos”，勾选“Kafka”, “HBase”, “HDFS”等。请参见《 MapReduce服务 用户指南》的“购买自定义集群”的章节创建MRS。 “安全组规则”开通对应UDP/TCP端口。详细内容请参考《私有云用户指南》中的“添加安全组规则”章节。 进入MRS manager管理界面： 创建机机账号，需确保该用户含有“hdfs_admin”, “hbase_admin”权限，下载该用户认证凭据，其中包含“user.keytab” 和 “krb5.conf” 文件。 由于人机账号的keytab会随用户密码过期而失效，故建议使用机机账号进行配置。 单击“服务管理”，下载客户端，单击“确定”。 在MRS节点上下载配置文件，所需集群配置文件包含“hbase-site.xml”和“hiveclient.properties”。 创建弹性资源池和队列。 弹性资源池与队列为 DLI 作业提供计算资源，创建弹性资源池，弹性资源池添加队列。 使用该DLI独享队列与MRS集群建立增强型跨源连接，且用户可以根据实际所需设置相应安全组规则。 如何建立增强型跨源连接，请参考《 数据湖探索 用户指南》中增强型跨源连接章节。 如何设置安全组规则，请参见《虚拟私有云用户指南》中“安全组”章节。 获取MRS集群全部节点的ip和 域名 映射，在DLI跨源连接修改主机信息中配置host映射。 如何添加IP域名映射，请参见《 数据湖 探索用户指南》中“修改主机信息”章节。 Kafka服务端的端口如果监听在hostname上，则需要将Kafka Broker节点的hostname和IP的对应关系添加到DLI队列中。Kafka Broker节点的hostname和IP请联系Kafka服务的部署人员。

支持的API列表 DLI JDBC Driver支持的API列表如下，对可能与JDBC标准产生歧义的地方加以备注说明。 Connection API支持的常用方法签名： Statement createStatement() PreparedStatement prepareStatement(String sql) void close() boolean isClosed() DatabaseMetaData getMetaData() PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency) Driver API支持的常用方法签名： Connection connect(String url, Properties info) boolean acceptsURL(String url) DriverPropertyInfo[] getPropertyInfo(String url, Properties info) ResultSetMetaData API支持的常用方法签名： String getColumnClassName(int column) int getColumnCount() int getColumnDisplaySize(int column) String getColumnLabel(int column) String getColumnName(int column) int getColumnType(int column) String getColumnTypeName(int column) int getPrecision(int column) int getScale(int column) boolean isCaseSensitive(int column) Statement API支持的常用方法签名： ResultSet executeQuery(String sql) int executeUpdate(String sql) boolean execute(String sql) void close() int getMaxRows() void setMaxRows(int max) int getQueryTimeout() void setQueryTimeout(int seconds) void cancel() ResultSet getResultSet() int getUpdateCount() boolean isClosed() PreparedStatement API支持的常用方法签名： void clearParameters() boolean execute() ResultSet executeQuery() int executeUpdate() PreparedStatement Set系列方法 ResultSet API支持的常用方法签名： int getRow() boolean isClosed() boolean next() void close() int findColumn(String columnLabel) boolean wasNull() get系列方法 DatabaseMetaData API支持的常用方法签名 ResultSet getCatalogs() 在DLI服务中没有Catalog的概念，返回空的ResultSet。 ResultSet getColumns(String catalog, String schemaPattern, String tableNamePattern, String columnNamePattern) Connection getConnection() getTables(String catalog, String schemaPattern,String tableNamePattern, String types[]) 该方法不采纳Catalog参数，schemaPattern对应DLI服务的database的概念。 ResultSet getTableTypes() ResultSet getSchemas() ResultSet getSchemas(String catalog, String schemaPattern)

步骤6：发送数据和查询结果 Kafaka端发送数据。 使用Kafka客户端向步骤2：创建Kafka的Topic中的Topic发送数据，模拟实时数据流。 Kafka生产和发送数据的方法请参考：DMS - 连接实例生产消费信息。 发送样例数据如下： {"order_id":"202103241000000001", "order_channel":"webShop", "order_time":"2021-03-24 10:00:00", "pay_amount":"100.00", "real_pay":"100.00", "pay_time":"2021-03-24 10:02:03", "user_id":"0001", "user_name":"Alice", "area_id":"330106"} {"order_id":"202103241606060001", "order_channel":"appShop", "order_time":"2021-03-24 16:06:06", "pay_amount":"200.00", "real_pay":"180.00", "pay_time":"2021-03-24 16:10:06", "user_id":"0002", "user_name":"Jason", "area_id":"330106"} 查看Elasticsearch端数据处理后的相应结果。 发送成功后，在 CSS 集群的Kibana中执行下述语句并查看相应结果： GET shoporders/_search 查询结果返回如下： { "took" : 0, "timed_out" : false, "_shards" : { "total" : 1, "successful" : 1, "skipped" : 0, "failed" : 0 }, "hits" : { "total" : { "value" : 2, "relation" : "eq" }, "max_score" : 1.0, "hits" : [ { "_index" : "shoporders", "_type" : "_doc", "_id" : "6fswzIAByVjqg3_qAyM1", "_score" : 1.0, "_source" : { "order_id" : "202103241000000001", "order_channel" : "webShop", "order_time" : "2021-03-24 10:00:00", "pay_amount" : 100.0, "real_pay" : 100.0, "pay_time" : "2021-03-24 10:02:03", "user_id" : "0001", "user_name" : "Alice", "area_id" : "330106" } }, { "_index" : "shoporders", "_type" : "_doc", "_id" : "6vs1zIAByVjqg3_qyyPp", "_score" : 1.0, "_source" : { "order_id" : "202103241606060001", "order_channel" : "appShop", "order_time" : "2021-03-24 16:06:06", "pay_amount" : 200.0, "real_pay" : 180.0, "pay_time" : "2021-03-24 16:10:06", "user_id" : "0002", "user_name" : "Jason", "area_id" : "330106" } } ] } }

场景描述 本示例场景对用户购买商品的数据信息进行分析，将满足特定条件的数据结果进行汇总输出。购买商品数据信息为数据源发送到Kafka中，再将Kafka数据的分析结果输出到Elasticsearch中。 例如，输入如下样例数据： {"order_id":"202103241000000001", "order_channel":"webShop", "order_time":"2021-03-24 10:00:00", "pay_amount":"100.00", "real_pay":"100.00", "pay_time":"2021-03-24 10:02:03", "user_id":"0001", "user_name":"Alice", "area_id":"330106"} {"order_id":"202103241606060001", "order_channel":"appShop", "order_time":"2021-03-24 16:06:06", "pay_amount":"200.00", "real_pay":"180.00", "pay_time":"2021-03-24 16:10:06", "user_id":"0002", "user_name":"Jason", "area_id":"330106"} DLI从Kafka读取数据写入Elasticsearch，在Elasticsearch集群的Kibana中查看相应结果。

整体作业开发流程 整体作业开发流程参考图1。 图1 作业开发流程 步骤1：创建队列：创建DLI作业运行的队列。 步骤2：创建Kafka的Topic：创建Kafka生产消费数据的Topic。 步骤3：创建Elasticsearch搜索索引：创建Elasticsearch搜索索引用于接收结果数据。 步骤4：创建增强型跨源连接：DLI上创建连接Kafka和 CS S的跨源连接，打通网络。 步骤5：运行作业：DLI上创建和运行Flink OpenSource作业。 步骤6：发送数据和查询结果：Kafka上发送流数据，在CSS上查看运行结果。

样例代码 本章节JAVA样例代码演示将DataGen数据处理后写入到OBS，具体参数配置请根据实际环境修改。 创建DLI访问DEW的委托并完成委托授权。 详细步骤请参考自定义DLI委托权限。 在DEW创建通用凭证。详细操作请参考创建通用凭据。 登录DEW管理控制台 选择“凭据管理”，进入“凭据管理”页面。 单击“创建凭据”。配置凭据基本信息 DLI Spark jar作业编辑界面设置作业参数。 Spark参数： spark.hadoop.fs.obs.bucket.USER_BUCKET_NAME.dew.access.key= USER_AK_C SMS _KEY spark.hadoop.fs.obs.bucket.USER_BUCKET_NAME.dew.secret.key= USER_SK_CSMS_KEY spark.hadoop.fs.obs.security.provider=com.dli.provider.UserObsBasicCredentialProvider spark.hadoop.fs.dew.csms.secretName=obsAkSk spark.hadoop.fs.dew.endpoint=kmsendpoint spark.hadoop.fs.dew.csms.version=v3 spark.dli.job.agency.name=agency 示例代码 示例代码请参考使用Spark Jar作业读取和查询OBS数据。