Socket Source
实时平台支持实时采集Scoket的数据。基础逻辑是当Socket推送消息时,平台通过固定消息长度或基于分隔符来判断哪些消息作为一段数据,然后写入下游。
下文介绍在向导模式中使用Scoket作为数据源的采集配置逻辑。
配置项操作和解释
- 操作页面:
参数解释:
配置 | 说明 |
---|---|
读取方式 | 支持按两种方式进行消息数据划分: 固定消息长度:当读取到的消息字符长度达到阈值时,将数据写入下游。否则会等待下一条消息来补足长度阈值。 分割字符串:识别消息中的指定字符,如“,”或者“;”等,当识别到时即作为一条数据写入下游。 |
解析规则 | 目前只支持text规则,即不对Socket数据进行处理,直接写入相应目标源。 |
采集起点 | 默认从任务运行时开始采集 |