检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
只能包含数字、字母、中划线“-”、下划线“_”。 最小长度：0 最大长度：43 响应参数 无 请求示例 批量删除资源标签 POST https://{Endpoint}/v2/{project_id}/stream/{stream_id}/tags/action { "action"
下载资源包。 在https://github.com/huaweicloud/huaweicloud-sdk-java-dis中下载DIS的Java SDK压缩包。 在DIS SDK桶中获取“huaweicloud-sdk-dis-java-X.X.X.zip ”压缩包，其中包含了示例工程demo包。
只能包含数字、字母、中划线“-”、下划线“_”。 最小长度：0 最大长度：43 响应参数 无 请求示例 批量添加资源标签 POST https://{Endpoint}/v2/{project_id}/stream/{stream_id}/tags/action { "action"
参数类型 描述 timestamp Long 时间戳。 value Long 时间戳对应的监控值。 请求示例 查询分区监控数据 GET https://{Endpoint}/v2/{project_id}/streams/{stream_name}/partitions/{partition_id}/metrics
timestamp_type String 时间戳类型。 CreateTime：创建时间。 缺省值：CreateTime 请求示例 下载数据 GET https://{Endpoint}/v2/{project_id}/records 响应示例 状态码： 200 正常返回 { "records"
EXPIRED：已过期 枚举值： CREATING ACTIVE DELETED EXPIRED 请求示例 查询App消费状态 GET https://{Endpoint}/v2/{project_id}/apps/{app_name}/streams/{stream_name} 响应示例
参数类型 描述 timestamp Long 时间戳。 value Long 时间戳对应的监控值。 请求示例 查询通道监控数据 GET https://{Endpoint}/v2/{project_id}/streams/{stream_name}/metrics 响应示例 无 SDK代码示例
error_code String 错误码。 error_message String 错误消息。 请求示例 上传数据 POST https://{Endpoint}/v2/{project_id}/records { "stream_name" : "newstream"
秒。默认配置为1800。配置为“0”表示DIS服务不会在转储失败时进行重试。 响应参数 无 请求示例 添加DLI转储任务 POST https://{Endpoint}/v2/{project_id}/streams/{stream_name}/transfer-tasks {
否 String 值。 对应的是企业项目ID，需要在企业管理页面获取。 36位UUID。 响应参数 无 请求示例 创建通道 POST https://{Endpoint}/v2/{project_id}/streams { "stream_name" : "newstream"
数据游标。 取值范围：1~512个字符。 说明： 数据游标有效期为5分钟。 最小长度：1 最大长度：512 请求示例 获取数据游标 GET https://{Endpoint}/v2/{project_id}/cursors 响应示例 状态码： 200 正常返回 { "partition_cursor"
d value String 值。 对应的是企业项目ID，需要在企业管理页面获取。 36位UUID。 请求示例 查询通道列表 GET https://{Endpoint}/v2/{project_id}/streams 响应示例 状态码： 200 正常返回 { "total_number"
单位：秒。 默认配置为1800。 配置为“0”表示DIS服务不会在转储失败时进行重试。 响应参数 无 请求示例 添加MRS转储任务 POST https://{Endpoint}/v2/{project_id}/streams/{stream_name}/transfer-tasks {
可从终端节点Endpoint获取。 安装Agent 在这里获取Agent安装包。 解压“dis-agent-X.X.X.zip”压缩包到当前文件夹。 准备数据样例 在这里获取数据样例压缩包。 解压压缩包到当前文件夹。 配置DIS Agent 使用文件管理器进入DIS Agent程
d value String 值。 对应的是企业项目ID，需要在企业管理页面获取。 36位UUID。 请求示例 查看通道详情 GET https://{Endpoint}/v2/{project_id}/streams/{stream_name} 响应示例 状态码： 200 正常返回
请根据实际情况配置 bodySerializeType 否 DIS数据包上传格式(非原始数据格式)。 json：DIS数据包封装为json格式，满足普通使用。 protobuf：DIS数据包封装为二进制格式，可以减少体积约1/3，在数据量较大的情况下推荐使用此格式。 json 父主题： 使用DIS
point即可 // props.setProperty(DISConfig.PROPERTY_ENDPOINT, "https://dis-${region}.myhuaweicloud.com"); Consumer<String, String>
Streaming Demo 这里获取“dis-spark-streaming-X.X.X.zip”压缩包。解压“dis-spark-streaming-X.X.X.zip”压缩包，解压之后获得以下目录： “dis-spark-streaming-demo”目录包含一个Maven工程样例。
point即可 // props.setProperty(DISConfig.PROPERTY_ENDPOINT, "https://dis-${region}.myhuaweicloud.com"); Consumer<String, String>
用于记录数据格式错误信息的错误表表名。并行导入结束后查询此错误信息表，能够获取详细的错误信息。 响应参数 无 请求示例 添加DWS转储任务 POST https://{Endpoint}/v2/{project_id}/streams/{stream_name}/transfer-tasks {
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
