数据接入服务 DIS-应用示例:创建带数据Schema的通道

时间:2024-10-21 14:17:49

创建带数据Schema的通道

您还可以为通道配置Schema,在使用DIS转储到其它服务时,可以根据通道配置的Schema来完成映射,示例如下。

  1. Token认证,具体操作请参考Token认证
  2. 发送“POST https://dis的Endpoint/v2/{project_id}/streams”。
  3. 在Request Header中增加“X-Auth-Token”。
  4. 在Request Body中传入参数如下:
    {
    "stream_name": "dis-DLpR",
    "partition_count": 1,
    "stream_type": "COMMON",
    "data_duration": 24
    "auto_scale_enabled": true,
    "auto_scale_min_partition_count": 1,
    "auto_scale_max_partition_count": 10
    "data_type": "JSON",
    "data_schema": 
    "{\"type\":\"record\",\"name\":\"RecordName\",\"fields\":[{\"name\":\"key1\",\"type\":\"string\"},{\"name\":\"key2\",\"type\":\"string\"}]}"
    }

    这个示例中创建了一个源数据类型为JSON,且数据包含“key1”、“key2”这两个属性的通道。

    • data_type:指定源数据的类型,“JSON”表示分区中的数据格式为JSON格式。
    • data_schema:源数据Schema,用于描述JSON、 CS V格式的源数据结构,采用Avro Schema的语法描述。

    请求响应成功后,返回201 Created,表示通道创建成功。

    若请求失败,则会返回错误码及对应的错误信息说明,详细错误码信息请参考错误码

support.huaweicloud.com/api-dis/dis_02_0003.html