管道管理-华为云

安全云脑 SECMASTER-create pipe (创建数据管道):Go

Go 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 package main import ( "fmt" "github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/basic" secmaster "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/secmaster/v2" "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/secmaster/v2/model" region "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/secmaster/v2/region" ) func main() { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security. // In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak := os.Getenv("CLOUD_SDK_AK") sk := os.Getenv("CLOUD_SDK_SK") auth := basic.NewCredentialsBuilder(). WithAk(ak). WithSk(sk). Build() client := secmaster.NewSecMasterClient( secmaster.SecMasterClientBuilder(). WithRegion(region.ValueOf("cn-north-4")). WithCredential(auth). Build()) request := &model.CreatePipeRequest{} request.Body = &model.CreatePipeRequestBody{ } response, err := client.CreatePipe(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } }

安全云脑 SECMASTER 管道管理

安全云脑 SECMASTER-create pipe (创建数据管道):请求示例

请求示例 { "dataspace_id" : "a00106ba-bede-453c-8488-b60c70bd6aed", "pipe_name" : "pipe-01", "description" : "test pipe", "storage_period" : 30, "shards" : 3, "mapping" : { "name" : { "type" : "text" }, "id" : { "type" : "text" }, "publish_time" : { "type" : "data" } }, "timestamp_field" : "_time" }

安全云脑 SECMASTER 管道管理

安全云脑 SECMASTER-create pipe (创建数据管道):Python

Python 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 # coding: utf-8 from huaweicloudsdkcore.auth.credentials import BasicCredentials from huaweicloudsdksecmaster.v2.region.secmaster_region import SecMasterRegion from huaweicloudsdkcore.exceptions import exceptions from huaweicloudsdksecmaster.v2 import * if __name__ == "__main__": # The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security. # In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = os.getenv("CLOUD_SDK_AK") sk = os.getenv("CLOUD_SDK_SK") credentials = BasicCredentials(ak, sk) \ client = SecMasterClient.new_builder() \ .with_credentials(credentials) \ .with_region(SecMasterRegion.value_of("cn-north-4")) \ .build() try: request = CreatePipeRequest() request.body = CreatePipeRequestBody( ) response = client.create_pipe(request) print(response) except exceptions.ClientRequestException as e: print(e.status_code) print(e.request_id) print(e.error_code) print(e.error_msg)

安全云脑 SECMASTER 管道管理

安全云脑 SECMASTER-create pipe (创建数据管道):Java

Java 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 45 46 47 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.secmaster.v2.region.SecMasterRegion; import com.huaweicloud.sdk.secmaster.v2.*; import com.huaweicloud.sdk.secmaster.v2.model.*; public class CreatePipeSolution { public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security. // In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment String ak = System.getenv("CLOUD_SDK_AK"); String sk = System.getenv("CLOUD_SDK_SK"); ICredential auth = new BasicCredentials() .withAk(ak) .withSk(sk); SecMasterClient client = SecMasterClient.newBuilder() .withCredential(auth) .withRegion(SecMasterRegion.valueOf("cn-north-4")) .build(); CreatePipeRequest request = new CreatePipeRequest(); CreatePipeRequestBody body = new CreatePipeRequestBody(); request.withBody(body); try { CreatePipeResponse response = client.createPipe(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()); } } }

安全云脑 SECMASTER 管道管理

安全云脑 SECMASTER-create pipe (创建数据管道):响应参数

响应参数状态码： 201 表5 响应Body参数参数参数类型描述 domain_id String 用户domainId 最小长度：32 最大长度：36 project_id String 项目id 最小长度：32 最大长度：36 dataspace_id String 数据空间id 最小长度：32 最大长度：36 dataspace_name String 数据空间名称最小长度：32 最大长度：36 pipe_id String 管道id 最小长度：32 最大长度：36 pipe_name String 管道名称最小长度：32 最大长度：36 pipe_type String 管道类型（system-defined，系统预定义)、1（user-defined，用户自定义) 最小长度：5 最大长度：128 description String 描述信息最小长度：5 最大长度：128 storage_period Integer 索引存储天数最小值：1 最大值：100000 shards Integer 索引分片数量最小值：1 最大值：128 create_by String 创建者最小长度：5 最大长度：128 create_time Integer 创建时间最小值：0 最大值：1010000000 update_by String 更新者最小长度：5 最大长度：128 update_time Integer 更新时间最小值：0 最大值：10000000000 状态码： 400 表6 响应Body参数参数参数类型描述 error_msg String 无效请求提示信息最小长度：1 最大长度：128 error_code String 错误码最小长度：1 最大长度：128 状态码： 401 表7 响应Body参数参数参数类型描述 error_msg String 权限错误最小长度：1 最大长度：128 error_code String 错误码最小长度：1 最大长度：128 状态码： 500 表8 响应Body参数参数参数类型描述 error_msg String 系统内部错误最小长度：1 最大长度：128 error_code String 错误码最小长度：1 最大长度：128

安全云脑 SECMASTER 管道管理

云服务器内容精选

管道管理

7*24

备案

专业服务

退订

建议反馈

售前咨询热线