00:00
好,那接下来呢,我们要做一个分流处理对吧?啊,那分流呢,要用到这个测输出流啊,那既然提到用测输出流的话,所以应该只能用process API了,对吧?那就是杰森o BJ with new flag DS点都要用process啊,那这边呢,有一个process方式啊,输入数据呢是杰森,呃,输出数据呢,因为我们要写到这个。写到这个卡夫卡里边对吧,卡夫卡里边的那个生产者我们写好了是string类型,所以这边呢,我就直接写成string类型对吧?写成类型好,那我们刚才看到了,其实要判断几种数据啊,直接从这里边就获取对应的字段就好了,对吧?那首先我们获取启动日志字段。啊,启动认知存在,那就Y6.getstring,然后呢是start。
01:01
CTRL加V得到一个start数据对吧,那如果if这个start。它不等于那啊,并且呢,start.lengths它大于零。啊,有数据,那说明它是一个启动日志,那我们将数据,将数据写入启动日志测输出流对吧?因为我们说了启动日志发测出流,所以在外面呢,我们应该搞一个标记,又一个output t,然后这里边呢是string类型,然后给一个ID。对吧,这个ID呢,我们就叫start。得到一个,这个out。搞一个这个start out t对吧?好,那这边呢,写出去那就Ctx.output然后呢,Start out t,然后呢,数据本身是Y6.tojthree,我们写成对类型写出去好了,好,那接下来我们看啊,在这个里边,其实除了启动日志,那还有另外的是页面和曝光,之前我们看到那页面长这个样子,曝光呢。
02:19
页面是有配置对吧,曝光呢,第二条数据是一个曝光,来,我把这条数据给他拿一下啊。曝光数据来看。它确实有place没有问题,但是曝光数据它本身是不是一条页面数据。是不是?就是说曝光数据它本身也是一个。页面日志吧。是不是对吧,所以呢,只要不是启动日志,我们就把它写到页面日志里边啊,就要写到页面日志对吧?好,那直接else。
03:00
将数据写入这个页面,日志主流啊,这个呢,我们放在主流。注意,主流的数据呢,拿out来写的,对吧?out.connect然后呢是Y6.toj写出去,好,那接下来我们取出数据中的曝光数据。啊,那就直接Y6.get切三瑞数组对吧?然后呢,曝光注意看字段不要写错了,曝光呢是display斯,注意有S啊,有同学之前写的时候呢,没加S出现问题了对吧?好,那我们把这个拿过来。而这杯得到一个place,但是它有没有可能为none啊?那是有可能的,对吧,我不能说所有的页面日日都是这个。曝光。对吧,我们可以说曝光都是页面,但不能说所有的页面都是曝光嘛,所以它有可能为no,那既然你有可能为no的时候,我们是不是要做一个判断。
04:08
做一个判断,If这个place它不等于no,并且。点点S要大于零。对吧,并且它的size要大于零才可以。对吧,好,那接下来我们既然是曝光数据,我们是不是趁着这个时候可以把数据压平给他写出去。对吧,我们可以把这个数据做一个压平处理啊,那就是说只要你等于零,那我们就place。呃,它是一个数组对吧,那我们看看有没有直接的for循环,哎,可以直接做这个for循环,这个for循环呢,但是不好,它是一个object的对吧,不方便处理,所以呢,我们这样做,我们怎么做呢?点size点。For I循环。然后接下来我们拿着点。
05:04
Get,接上set,因为这样的话方便我们处理对吧?好,这个呢,我们只能叫def display。啊,注意看啊,上面是有S,这个没有S啊,就单个电子分类数据,那我们要把它写出据,但是呢,由于我们说了你曝光一定在于页面当中,所以呢我们添加。页面ID啊,把页面ID也放进来再写出啊,当然了,除了添加页面ID,咱们是不是还可以添加这个公共字段这些东西,你想加什么,把这些东西都加进去,对吧,不光要做压平了,也就是说现在我们要做什么事呢?这里面九个,那进来一条数据,我要输出九条。啊,我要输出这个九条数据。我要输出九条数据,哎,这边这个屏断了,所以说直接就弹出来了,那我们要输出这个九条数据。
06:00
对吧,啊,输出九条数据,那这个九条数据当中呢,我们看到它呢,还属于页面,还属于页面,所以我们接下来想把什么呢?把这个页面的ID也写到这个里边啊,当然你要得把公共字段写进来也可以,这个你就随便了。啊,这个你就随便了,好吧,那我们就写一个添加页面ID啊呃,页面ID呢,那首先我们在这里边除了获取曝光数据啊,只要它不为呢,对吧,我们获取这边获取页面D页面ID,刚才我们看到它属于配置当中叫配置D,对吧?啊那我们就直接Y6.get接3OBJECT,然后呢是page当中的点get string叫paged,得到一个page ID,好那接下来呢,添加进去,那这个很简单,就display点。Put啊,或者说我们叫put put一个K对吧,Put k呢,我们就叫page ID,然后Y6。
07:04
注意Y6呢,就是配宅力对吧,当然你要想放公共字段也可以。啊,也可以放进来,也可以放进来,就是你随便了,这个就是你看你对吧,好,那放进来以后呢,将数据写出道叫曝光。测输出流好曝光的一个测输出流对吧?好,那这边呢,我们就直接再来一个测出流标记啊,这边有一个out time。这个地方呢,还是string类型。然后ID display。这列好,那这边呢。加一下,看到大家回车,这个呢叫第play哈。啊,或者说直接叫这个tag好display tag对吧?啊,那这边呢,我们就可以写出去叫CDx.out然后呢,Display数据是我们的display.to Jason string啊就是炸开之后的数据,看这是一个循环病例,对吧?假如说我们当前数据当中有九个曝光字段,那这个就输出九次,那不就是。
08:17
炸裂出去了对吧,炸裂出去了,好这个CTRL加V得到一个注意,这个是主流,主流呢是配置。啊,就是配置一个DS页面啊,页面日志主流对吧?啊,那这个搞定,提取测试的数据,这个就简单了,呃,那配置DS.get set out,把这个start time扔进去。看家得到一个start.s好,同样的配置点s.get display好,这个呢,就得到一个第3PLAY的一个yes。对吧,啊displays好,接下来呢,我们先做这个打印对吧,Start DS点。
09:04
好,这个呢,我们要加参数了啊,因为有多个日志对吧,那配置s.print。Page。哎,这个地方怎么调用这个不对啊,叫print。好配置,我们也加一个配置,那这样还有一个display。Display。我们可以做一个数据的打印,对吧,最后呢,启动任务d.Excel。呃,然后接下来呢,把我们当前这个业务拿过来叫贝APP,对吧,把这个拿到最后。啊,拿到最后这个就好了啊,这就搞定了,接下来呢,回到上面,我们把这个拿干掉,这个就掉了,对吧?啊,多余的依赖我们都给干掉。好,那现在呢,这块我们编码就整个的搞定了啊,最后测试流打印对吧,当然了,还有一个写到呃,卡卡主题啊,写到卡卡主题,当然我们也可以把这个加上去一块来测啊,呃,那你要不放心,你先打印测试,然后再加进去,这个都无所谓,行,那我们就一块加进去啊,那就是start DS。
10:18
加进去start.s.ADD think啊,这边呢叫my KA YouTube.get KA producer主题DWD。Start log。好,那接下来page点点I think叫MY卡点get卡producer dwd叫page。Lock,对吧,好,最后一个display。点think啊,那我们可以一把来测啊,麦卡点加卡producer,然后DWD叫display log啊,就是DWD层的三个主题对吧,三个都是卡夫卡的一个主题,那这个呢就搞定编码这个搞定,接下来我们要做测试啊。
我来说两句