数据接入服务 DIS-应用示例:创建带数据Schema的通道
创建带数据Schema的通道
您还可以为通道配置Schema,在使用DIS转储到其它服务时,可以根据通道配置的Schema来完成映射,示例如下。
- Token认证,具体操作请参考Token认证。
- 发送“POST https://dis的Endpoint/v2/{project_id}/streams”。
- 在Request Header中增加“X-Auth-Token”。
- 在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,表示通道创建成功。
若请求失败,则会返回错误码及对应的错误信息说明,详细错误码信息请参考错误码。