Skip to main content

Socket Source

实时平台支持实时采集Scoket的数据。基础逻辑是当Socket推送消息时,平台通过固定消息长度或基于分隔符来判断哪些消息作为一段数据,然后写入下游。

下文介绍在向导模式中使用Scoket作为数据源的采集配置逻辑。

配置项操作和解释

  • 操作页面:

image-20220629165008837

参数解释:

配置说明
读取方式支持按两种方式进行消息数据划分:
固定消息长度:当读取到的消息字符长度达到阈值时,将数据写入下游。否则会等待下一条消息来补足长度阈值。
分割字符串:识别消息中的指定字符,如“,”或者“;”等,当识别到时即作为一条数据写入下游。
解析规则目前只支持text规则,即不对Socket数据进行处理,直接写入相应目标源。
采集起点默认从任务运行时开始采集