多语言展示
当前在线:180今日阅读:126今日分享:42

CamBuilder数据源接入流程

DIX是CamBuilder中用于实时对接入数据进行处理后输出到指定目的地的系统。可以用来接入Mysql、ActiveMq,syslog等数据源中存储的数据,可以在接入这些数据源存储的数据后,利用DIX对数据进行简单处理后,输出到指定的数据源,目前支持MySql、ActiveMq等。
一、接收MySQL数据
2

2.进入如下界面,在黑窗口的run函数中编写JavaScript脚本,将获取到的数据转换成产品需要的数据结构,最后输出。首先编写脚本获取数据,获取数据有2种方式,第一种是主动获取,第二种是被动接收,根据实际情况选择对应的获取数据方式。而每一种方式又有多种类型。

3

3.对接MySQL我们选择主动获取方式,点击输入-主动获取,选择第一项MySQL ,相应的接入MySQL的代码会自动填写在function run() 里面 ,in 为接入语句,executes为数据处理逻辑,outs处填写数据输出语句。如下图,在1处添加接入MySQL数据源url,username,password,在2处添加查询简单的查询sql语句,查询自己需要的数据。

二、接收ActiveMq数据
1

1.点击JavaScript,进入配置页面,在1处填入dip名字,2处的地址为宿主机地址,默认为dip系统部署机器地址, 点击下一步,填写脚本配置。dip名称:使用英文且见名知义(最好使用驼峰命名法)。dip的宿主机:运行该dip的服务器ip地址,也是我们的数据处理服务器。

2

2.进入如下界面,点击输入-被动接受,选择第一项 ,相应的接入ActiveMq 的代码会自动填写在function run() 里面 in 为接入语句,executes为数据处理逻辑,outs处填写数据输出语句。如下图,在1处依次填入ActiveMq数据源的url,queue,username,pasword,最后一个参数为true,表示接受queue,为false表示接受topic,URL: MQ的地址,格式为tcp://${ip}:${port},例如tcp://192.168.10.44:61616对列名queue: 产品接收的指定队列noah_perfs.用户名username: admin密码password: admin

三、接收Syslog数据
1

1.点击JavaScript,进入配置页面,在1处填入dip名字,2处的地址为宿主机地址,默认为dip系统部署机器地址, 点击下一步,填写脚本配置。dip名称:使用英文且见名知义(最好使用驼峰命名法)。dip的宿主机:运行该dip的服务器ip地址,也是我们的数据处理服务器。

2

2.进入如下界面,在1处点击输入-被动接受,选择第一项 ,相应的接入Syslog 的代码会自动填写在function run() 里面 in 为接入语句,executes为数据处理逻辑,outs处填写数据输出语句。IN配置是指接收syslog告警数据必须的一些信息,根据具体的需求调研填写依次填入Syslog数据源的url,port,protocal,主机url:部署DIP服务端程序的主机IP端口port:与第三方厂商syslog确认的syslog数据推送端口,建议填写大于1600的未被其他服务占用的端口,协议protocal:与第三方厂商syslog确认进行syslog数据传输协议,可选UDP或TCP接入syslog数据库

推荐信息