更新时间:2024-10-21 GMT+08:00

创建通道

功能介绍

本接口用于创建通道。

  • 创建通道时,需指定通道类型(普通、高级)、分区数量。

  • 一个账号默认最多可以创建10个高级通道分区和50个普通通道分区,可提交工单增加配额。

调用方法

请参见如何调用API

URI

POST /v2/{project_id}/streams

表1 路径参数

参数

是否必选

参数类型

描述

project_id

String

项目ID。

请求参数

表2 请求Header参数

参数

是否必选

参数类型

描述

X-Auth-Token

String

用户Token。

通过调用IAM服务获取用户Token接口获取(响应消息头中X-Subject-Token的值)。

表3 请求Body参数

参数

是否必选

参数类型

描述

stream_name

String

通道名称。

通道名称由字母、数字、下划线和中划线组成,长度为1~64字符。

最大长度:64

partition_count

Integer

分区数量。

分区是DIS数据通道的基本吞吐量单位。

stream_type

String

通道类型。

  • COMMON:普通通道,表示1MB带宽。

  • ADVANCED:高级通道,表示5MB带宽。

枚举值:

  • COMMON

  • ADVANCED

data_type

String

源数据类型。

  • BLOB:存储在数据库管理系统中的一组二进制数据。

  • JSON:一种开放的文件格式,以易读的文字为基础,用来传输由属性值或者序列性的值组成的数据对象。

  • CSV:纯文本形式存储的表格数据,分隔符默认采用逗号。

缺省值:BLOB。

枚举值:

  • BLOB

  • JSON

  • CSV

data_duration

Integer

数据保留时长。

取值范围:24~72。

单位:小时。

空表示使用缺省值。

缺省值:24

auto_scale_enabled

Boolean

是否开启自动扩缩容。

  • true:开启自动扩缩容。

  • false:关闭自动扩缩容。

默认不开启。

缺省值:false

auto_scale_min_partition_count

Long

当自动扩缩容启用时,自动缩容的最小分片数。

最小值:1

auto_scale_max_partition_count

Integer

当自动扩缩容启用时,自动扩容的最大分片数。

data_schema

String

用于描述用户JSON、CSV格式的源数据结构,采用Avro Schema的语法描述。

csv_properties

CSVProperties object

CSV 格式数据的相关属性,比如分隔符 delimiter

compression_format

String

数据的压缩类型,目前支持:

  • snappy

  • gzip

  • zip

默认不压缩。

枚举值:

  • snappy

  • gzip

  • zip

tags

Array of Tag objects

通道标签列表。

sys_tags

Array of SysTag objects

通道企业项目列表。

表4 CSVProperties

参数

是否必选

参数类型

描述

delimiter

String

数据分隔符。

表5 Tag

参数

是否必选

参数类型

描述

key

String

键。

  • 不能为空。

  • 对于同一资源键值唯一。

  • 字符集:A-Z,a-z , 0-9,‘-’,‘_’,UNICODE字符(\u4E00-\u9FFF)。

最小长度:1

最大长度:36

value

String

值。

  • 长度不超过43个字符。

  • 字符集:A-Z,a-z , 0-9,‘.’,‘-’,‘_’,UNICODE字符(\u4E00-\u9FFF)。

  • 只能包含数字、字母、中划线“-”、下划线“_”。

最小长度:0

最大长度:43

表6 SysTag

参数

是否必选

参数类型

描述

key

String

键。

  • 不能为空。

  • 值必须为_sys_enterprise_project_id。

status

String

枚举值:

  • _sys_enterprise_project_id

value

String

值。

  • 对应的是企业项目ID,需要在企业管理页面获取。

  • 36位UUID。

响应参数

请求示例

创建通道

POST https://{Endpoint}/v2/{project_id}/streams

{
  "stream_name" : "newstream",
  "partition_count" : 3,
  "data_duration" : 24
}

响应示例

SDK代码示例

SDK代码示例如下。

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
48
49
50
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.dis.v2.region.DisRegion;
import com.huaweicloud.sdk.dis.v2.*;
import com.huaweicloud.sdk.dis.v2.model.*;


public class CreateStreamSolution {

    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);

        DisClient client = DisClient.newBuilder()
                .withCredential(auth)
                .withRegion(DisRegion.valueOf("<YOUR REGION>"))
                .build();
        CreateStreamRequest request = new CreateStreamRequest();
        CreateStreamReq body = new CreateStreamReq();
        body.withDataDuration(24);
        body.withPartitionCount(3);
        body.withStreamName("newstream");
        request.withBody(body);
        try {
            CreateStreamResponse response = client.createStream(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());
        }
    }
}

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
32
33
34
35
# coding: utf-8

import os
from huaweicloudsdkcore.auth.credentials import BasicCredentials
from huaweicloudsdkdis.v2.region.dis_region import DisRegion
from huaweicloudsdkcore.exceptions import exceptions
from huaweicloudsdkdis.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.environ["CLOUD_SDK_AK"]
    sk = os.environ["CLOUD_SDK_SK"]

    credentials = BasicCredentials(ak, sk)

    client = DisClient.new_builder() \
        .with_credentials(credentials) \
        .with_region(DisRegion.value_of("<YOUR REGION>")) \
        .build()

    try:
        request = CreateStreamRequest()
        request.body = CreateStreamReq(
            data_duration=24,
            partition_count=3,
            stream_name="newstream"
        )
        response = client.create_stream(request)
        print(response)
    except exceptions.ClientRequestException as e:
        print(e.status_code)
        print(e.request_id)
        print(e.error_code)
        print(e.error_msg)

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
38
39
40
41
package main

import (
	"fmt"
	"github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/basic"
    dis "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/dis/v2"
	"github.com/huaweicloud/huaweicloud-sdk-go-v3/services/dis/v2/model"
    region "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/dis/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 := dis.NewDisClient(
        dis.DisClientBuilder().
            WithRegion(region.ValueOf("<YOUR REGION>")).
            WithCredential(auth).
            Build())

    request := &model.CreateStreamRequest{}
	dataDurationCreateStreamReq:= int32(24)
	request.Body = &model.CreateStreamReq{
		DataDuration: &dataDurationCreateStreamReq,
		PartitionCount: int32(3),
		StreamName: "newstream",
	}
	response, err := client.CreateStream(request)
	if err == nil {
        fmt.Printf("%+v\n", response)
    } else {
        fmt.Println(err)
    }
}

更多

更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。

状态码

状态码

描述

201

Created

错误码

请参见错误码