etl engine 读写redis原创

下面我们为大家介绍。通过ETL engine读写redis。我们的需求是实现。读取radius当中的一个或多个T。写到目标RA中。我们的前置条件。通过配置一台reddis服务器。读取其中DB0当中的某个T。并写入到DB1来模拟上述的场景。配置读写任务的关键环节是。配置，读redis节点，写red节点。创建源数据。配置连接线。我们登录到管理端后台。打开设计器。

打开一个我们事先已经配置好的任务。我们看一下。任务主要由读redis节点和写reddis节点组成。Do redis节点当中主要设置服务器的地址。密码和DB的索引号。当前原radius我们配置DB属性是0。最关键的是pattern match t要设置成true。Keys, 我们配置一个key的名称。单独写一个P。我们看一下。Reddis管理端DB0当中有27个T。读redis节点中。TS属性配置budget input.

未读取key的名称。D be当中有0个T。我们实现将。DB0当中的一个。T写到d be当中。我们看一下。She reddis同样配置服务器名称。地址密码。目标DB配置为1属性。Pon magic key配置成true。Output FS设置固定的字段名称为key value kttl.Rename output FS同样也是这样配置。

我们看一下。说明。Do redis节点。Matcht属性设置成true的时候。我们可以在kiss属性当中设置通配符的方式。来实现读多个T的名称。当设置pattern matcht为true时。我们的系统会默认生成。原数据的结构是3个字段。TTTTL.用于读写操作。She radisus节点。同样，Pattern match key要设置成true。再看一下我们的原数据。

设置了KKTT的字段类型都是字符串。设置完读节点、写节点和原数据之后。我们要配置一个连接线。连接线当中要选择原数据。是创建的Meta data.保存我们的任务。运行一下。我们看一下。执行情况。后台的日志分析。这是我们刚刚执行的一条任务。输出的结果我们可以看一下。读一条，写一条。

已经成功了。Radius服务器。D be当中。易经。将DB0当中的T读写进来。我们清空一下DB1。我们在做一个模拟。读节点当中，我们使用通配符。哈6前缀。后面加一个字符代表读取哈前缀所有P。那么。任务执行的时候。会读取hab前缀通配符的所有key。

写到目标的RA当中，我们保存。看一下我们的DB0。哈，前缀有3个T。那我们最终的效果d be当中，将这3个T读写进来。运行一下。我们查一下日志。这是刚刚运行成功的。我们看一下。读了3条。写了3条。我们看一下DB1。的确。3个哈前缀的key已经全部读写进来。那么总结一下。

我们最关键的配置就是读写节点。设置petta matcht为true。写节点，设置output fields.Rename output fields为固定的3个T。TTTTL.原数据创建了3个字段。跟这两个属性值一一匹配。然后为连接线配置原数据。