检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
数据接入服务”。 单击现有通道列表右上角的“标签搜索”，展开查询页。 输入待查询通道的标签。 标签键或标签值可以通过下拉列表中选择，当标签键或标签值全匹配时，系统可以自动查询到目标通道。当有多个标签条件时，会取各个标签的交集，进行通道查询。 单击“搜索”。 系统根据标签键或标签值搜索目标通道。
ey不能重复，同一个key中values不能重复。 matches 否 String 搜索字段，key为要匹配的字段，当前仅支持resource_name。value为匹配的值。此字段为固定字典值 表4 Tags 参数 是否必选 参数类型 描述 key 否 String 键。 不能为空。
否 String 转储文件的记录分隔符，用于分隔写入转储文件的用户数据。 取值范围： 逗号 ","，默认值 分号 ";" 竖线 "|" 换行符 "\n" 缺省值：\n 表5 ProcessingSchema 参数 是否必选 参数类型 描述 timestamp_name 是 String
Notification，消息通知服务）发送DIS事件的通知，订阅DIS事件即可启用通知。在订阅中，用户需要指定一个或多个事件筛选条件。每当发生与所有筛选条件匹配的事件时，DIS就会通过该订阅发送通知。筛选条件包含事件类别（例如：管理、监控或安全）、事件级别（例如：正常或警告）和事件源类型（例如：通道或转储任务）。
图说DIS 图说ECS 立即使用 成长地图 由浅入深，带您玩转DIS 01 了解 了解华为云DIS的产品架构、功能和基础知识，有助于您更准确地匹配实际业务，让数据上云变得更简单、更方便。 产品介绍 什么是DIS DIS功能介绍 DIS应用场景 DIS基本概念 03 入门 指导用户通过DIS
SDK进行二次开发前需要进行的初始化工作。 Python：准备环境~~获取数据游标 介绍使用DIS SDK进行的常用操作（匹配python）。 Java：准备环境~~变更分区数量 介绍使用DIS SDK进行的常用操作（匹配java）。 DIS服务端错误码 介绍使用DIS SDK过程中遇到异常时的响应信息。 父主题：
下载流式数据 背景信息 下载流式数据，需要确定从分区的什么位置开始获取（即获取游标）。确定起始位置后，再循环获取数据。 获取游标有如下五种方式： AT_SEQUENCE_NUMBER AFTER_SEQUENCE_NUMBER TRIM_HORIZON LATEST AT_TIMESTAMP
将“filePattern”所匹配到的文件内容按分隔符解析并上传到此通道。 请根据实际情况配置 filePattern 是 文件监控路径，只能监控一个目录下的文件，无法递归目录监控。 如果要监控多个目录，可以在flows下面配置多个“DISStream”，文件名可使用“*”进行匹配。 “/tmp/*
此配置项仅支持选择，不可手动输入。 - 记录分隔符 进行OBS转储时，分隔不同转储记录的分隔符。 取值范围： 逗号 "," 分号 ";" 竖线 "|" 换行符 "\n" NULL 此配置项仅支持选择，不可手动输入。 - 偏移量 最新：最大偏移量，即获取最新的有效数据。 最早：最小偏移量，即读取最早的有效数据。
参数为true/on，若数据源文件比外表定义列数多，则忽略行尾多出来的列。 参数为false/off，若数据源文件比外表定义列数多，会显示如下错误信息。 说明： 如果行尾换行符丢失，使两行变成一行时，设置此参数为true将导致后一行数据被忽略掉。 compatible_illegal_chars 导入非法字符容错参数。此语法仅对READ
void subscribe(Pattern var1, ConsumerRebalanceListener var2) 接口 支持 订阅所有匹配通配符的通道并支持ConsumerRebalanceListener回调 void unsubscribe() 接口 支持 取消所有订阅 ConsumerRecords<K
void subscribe(Pattern var1, ConsumerRebalanceListener var2) 接口 支持 订阅所有匹配通配符的通道并支持ConsumerRebalanceListener回调 void unsubscribe() 接口 支持 取消所有订阅 ConsumerRecords<K
record_delimiter String 转储文件的记录分隔符，用于分隔写入转储文件的用户数据。 取值范围： 逗号 ","，默认值 分号 ";" 竖线 "|" 换行符 "\n" 缺省值：\n 表6 ProcessingSchema 参数 参数类型 描述 timestamp_name String 源数据时间戳的属性名称。
处理方法：检查Agent所在日志服务器的网络配置是否可以连接公网。 查看Agent是否上传日志。 “agent.yml”中配置的监控目录下有匹配的文件，日志中会输出类似如下日志，表示解析了[N1行(B1字节数)/N2文件(B2字节数)]，成功上传了[N3行/N4文件]。 Agent:
是提高Rest接口的上传效率 batch.size 参数 支持 含义与kafka设置相同，但默认值为1MB(kafka是16KB)，目的是匹配流控的大小 buffer.memory 参数 支持 同kafka的默认设置(32MB) max.in.flight.requests.per
是提高Rest接口的上传效率 batch.size 参数 支持 含义与kafka设置相同，但默认值为1MB(kafka是16KB)，目的是匹配流控的大小 buffer.memory 参数 支持 同kafka的默认设置(32MB) max.in.flight.requests.per
将“filePattern”所匹配到的文件内容按分隔符解析并上传到此通道。 请根据实际情况配置 filePattern 是 文件监控路径，只能监控一个目录下的文件，无法递归目录监控。 如果要监控多个目录，可以在flows下面配置多个“DISStream”，文件名可使用“*”进行匹配。 “/tmp/*
是使用通配符，例如stream.* 表示会消费 stream1, stream2, stream_123等等。已有/新增/删除的通道，只要匹配通配符，就可被消费组消费。 代码样例如下所示： package com.huaweicloud.dis.demo.adapter; import
是使用通配符，例如stream.* 表示会消费 stream1, stream2, stream_123等等。已有/新增/删除的通道，只要匹配通配符，就可被消费组消费。 代码样例如下所示： package com.huaweicloud.dis.demo.adapter; import
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
