34_尚硅谷_数仓采集_分类型拦截器

好，刚才呢，我们把这个ETF拦截器已经写完了，那下面这个就是要区分类型拦截器，区分类型拦截器在里面我们要做什么事呢。将它分开啊，分别发往不同的它里面去，那分开的手段就是将弗鲁姆包底里的数据按照类型不同标记为不同的hi ho啊，放到这里面，然后这里面就能读到对应的header啊，然后发往不同的。它进去啊，是这么一个过程，那好，那下面呢，我们就在这个啊，制定一个分类型来截器。找到这个类名。这儿。继续创建啊，还是在这个拦截器里面啊，日后呢，我们统一的打包发送到这个咨询上啊。美名。那么它的实现步骤第一步，第一个类实现intercept接口。

In。2CP啊，这个里面重写的四个方法。四个方法，其中啊两个，一个是初始化，一个是关闭啊，另一个呢是单一文的处理啊，接下来是多一文档处理，那同样我们还是在这个单页里面先进行一个处理啊处理，那这里面是进来一个阶层数据。啊，出去的话，希望它是对应的start和event啊，那这个event呢，都是放到he里面去，放到。对，Header并不是这个改变，它body底的数据，包底的数据不做改变啊，他改的是啊，在header里面标记，那好，那既然是这样的事，那我就还是得先获取body的数据啊，获取包数据，那body数据的话就是一。

第二盖的房顶。啊，拿过来，那同样还是另一个时间。这个使劲呢，别导错包了啊，有的时候不小心就倒上面这包了，那你后面就都错了啊啊注意这个使劲里包啊发有点儿杠吧。好，那这样呢，就拿到了那个数据啊，包底的数据拿到它之后，那下边我还要获得的头啊，头也是过去开的。Head，那获had的话也是用这个in.get。

好，那这样呢，就拿到了这个。拿到它之后，我要向这个师里面去添加它的key和value啊value，那这个value根据什么呢。根据它对吧，啊给他，那他怎么判断。Hi，里面添加是。那电加值的话啊，就是一，那如果这里面。包含。Start吧，Start，那它说明是启动是。那如果是启动日志的话，那代表header.put啊，那它的P是。

Topic啊，那这个topic啊，跟我们这块配置有关系，你看我们这块。你看它就是它啊，然后对应的不同的值啊，不同的值，好，那拿回来吧。那这一块也就是他的一个啊，里面放的是第一个to PC啊，它的一个star。OK，那下一个简单了。拿过来这呢就变成一。好，那这个呢，就是将这个包里的数据标记为不同的类型啊，都放到这个topic里面去了啊，只不过一个是放一个放。啊，那后面这个传选择器，根据这两个匹配就能发往不同的传统里面去，那这一块返回什么呢。

仍然是返回event，因为包地里的数据你不需要做任何的修改。只是把这个。包点取出来，用于判断它是放到哪一个开里面去啊，这件事OK，好，这是对应的单个处理完之后，那剩下的事。多个英文的及格处理，那在这里面又要干什么事呢？直接返回是不是就OK了啊，那这里面你为了一个进一步的一个解耦的话，你可以。At。要循环便利一下啊，再定义一个第三个啊，就额外的一个集合啊，来用于这个，防止这里面数据被修改啊，你就放一个。那怎么办呢？Intercept啊，也就说这个intercept调用的就是上面这个方法，OK，那同样还是intercept。

然后。啊，E和判断啊，不用判断了啊，不用判断了，直接再来一个集合就行了，另外一个A2R等于二。好，INC2IN34，那直接向这个额外的这个集合里面去添加数据点2IN31啊就OK了，那最终返回的就是一个IN34啊，这就结三到啊，属于一个结偶啊判断，否则的话，这里面在别的地方对它进行一个修改，容易影响你后面的一个结果，好，那这个判断完之后，那就剩最后一个啊build。他们哪个来哪个啊。

啊，Plus，然后build。好，然后实现intercept点用。啊。二加工实现。那这个搞定之后，这放一个另一个对象left type intercept搞定。那这样呢，这是两个拦截器，我们就都做完了，这个呢，其中是这个分类型的拦截器，分类型拦截器在解题当中用的还是比较多的啊，基本上就把这个数据类型啊，进一步的一个分开啊，分成start和一本啊，分成企业开发当中，这里面可能分呃十多个topic都是有可能的。比如说我们12张表啊，正常情况下可以一张表一个topic。啊都可以啊，都可以后面跟大家说按照什么去分这个那打包。

Thankyou。这个拦截器算这里面比较难的了，今天啊，当然也不是特别难，缺点代码。行编译完成。然后来到这里面，又见。进来，那这里面我选择哪一个呢。理由是什么？选择哪一个带依赖和不带依赖啊，不带依赖为什么？因为我这个这个拦截器里面只用了姆它的一个加号法啊，没有其他依赖，那我这个机器上有没有姆那个依赖，有吧，啊那就不需要再安装了，如果你这里面额外的有其他那个依赖，那你可以把它打过来啊，而且这里面如果有其他依赖的话，还要注意跟你这个项目的版本是否一致，必须要一致，否则会报一个异常，好那这边。

把这个价包放到CDOBD放到那个包厢啊，另包厢。我拽过来。啊，不带依赖的拖拽过来之后要记得啊，来到这个地方要分发。来这里面啊，这里面有很多包，你可以看一下，其中有一个intercept，我们刚发过来的。找到了吗？啊，这是这个吧，啊这个那你要把它分发到其他节点上啊，就是。那这样的这个啊，他也就搞定了，那搞定之后剩下的事啊，我们要干什么呢？我是要启动这个风网啊，就要启动这个风了啊。

那起到我们直接可以起呀。这个agent杠杠name ne1啊杠杠com也说配置文件，配置文件呢，在这个com下有一个file卡普卡啊这个呢是在后台运行是动作吗？啊直接可以拿过来运行一下。那你说我现在运行能看到什么效果吗？目前呢，你是看不到太明显的效果的啊，啊不容易啊启动。不。啊，那这里面呢，就起到了一个application啊，这个application呢，其实就是这个启动这个进程啊，另一个呢，我就不提了啊啊不提了，那一会呢，呃，我正常情况下还需要去103上再启动它啊，每次去每个节点去启动这个进程很。

麻烦啊，只要很麻烦的事情，就要把它做成脚本好。