00:00
好,那接下来呢,我们就要写我们的一个代码了,那这个代码呢,我就把这个拿过来啊,叫product APP啊,在我们的DWS啊,我们来的第二张表。叫product APP啊好,那这个东西呢,我们把它拿过来,然后呢,在这边首先我们还是一样的把这个步骤去写一下。啊。第一个第一步,我们相当于整理一下我们刚才分析的那个思路啊,第一步获取执行环境对吧,第二。读取卡夫卡数据,创建流。啊,要创建这个流对吧?啊,当然呢,这个地方是七个主题。七个主题的数据对吧,我们创建流,创建流好以后接下来呢。
01:00
加七个流。统一数据格式对吧,统一的数据格式呢,就是我们的product states啊,这个招B啊统一人它好,那这个统一好了之后,我们就可以做第四步unit。七个。合并我们的七个流。对吧,合并起来,合并好以后,我们之前说了要关联维度放在最后对吧,那第五步就是要做什么事,提取时间戳生成摩mark啊,生成我们那一个的摩mark,然后我们把这个分开写啊生成摩之后呢,我们要分组。然后开窗。聚合,那这个呢,我们就可以放在一块了,分组按照SKU。ID分组对吧,开窗十秒的。
02:02
滚动窗口啊聚合呢,结合什么,这个增量聚合和全量聚合。对吧,那增量聚合呢,累加值啊,它的作用是累加值啊,那全量聚合呢,提取窗口信息。对吧,它的作用是提取这个窗口信息,好,那接下来我们继续。开装聚合好以后注意要关联维度了。关联维度信息,那在这个当中我们写一下7.1,那还是一样的,我们要关联的无非就是s ku trade bug categ,那这四张表还记得之前。一定要先关联SKU,然后关联其他三张表,那只要把SKU关联好了之后,其他的三张表是不是无所谓啊,顺序就无所谓了,对吧,所以在这边呢,我们写一下要关联这个SKU维度。
03:07
好,然后7.2关联SPU维度。7.3对吧,关联我们的垂百度啊,那7.4。关联。最后开。这个维度对吧,好关联好维度以后呢,我们数据就完成了。那就是第八步,将数据写入。那第九步。启动任务。OK吧,思路上有没有问题?思路我们整理了一下也没问题啊,应该还好吧,因为这个思路呢,跟我们之前的思路都一样,只不过说只有这个地方有区别。
04:08
只有这一个地方有区别对吧,我们最后呢,要去关联一下这个维度信息给他写出去,对吧,就这样描写好,那前面呢,我们把这个写一下,把这个东西写一下,呃,那首先执行环境我从这拿一下啊。好,接下来读取七个流的数据,那我们也写一下吧,这个东西啊,我把这个拿过来。好,那直接就是Env.S。对吧,然后麦卡过U。Get consumer啊,然后呢,是呃,从这个配置版。配置。然后呢钩BYD啊把它写上对吧,加V得到一个PV的一个点。
05:02
当然这个不是用来算这个PV,是out click对吧?Page view啊,我们就只写了一个这个page view,好,那继续还有Inv.at source,然后第二个。是all white,假如说按照这个来写吧,或者说这样,咱们按照这个来写吧。首先第一个配置view当中呢,能获得点击和曝光对吧?呃,第二个收藏,那收藏的话咱们是这个。Topic,然后grow,诶不是at呢,还是叫my YouTube.get一个consumer对吧,然后呢,Favorite收藏,然后呢,Group。好卡R加V得到一个F的一个点子啊,收藏这个流啊,加一个R尔吧。演完它单词总是给我们标下划线那个波浪线对吧,好收藏好定,然后接下来呢,加购物车啊,然后Inv.at source my,卡卡,YouTube,这个就是体力活对吧,大家要注意一下,自己去写一写就好了,Cut,然后gor加倍得到一个cut。
06:14
点购物车流对吧,接下来呢,是收藏加购物车订单,那就是因为点I叫MY卡YouTube点卡。然后勾入白,得到一个凹的。DS订单啊,呃,订单支付那还是一样的。点,然后呢,Payment诶。然后是group ID对吧,这个就得到了一个配的DS啊,那么就简写了,同样的接下来呢是退款。这款是aph phone group对吧,好,再得到一个。
07:02
第二啊,退单的,其实我们用的是退单表,用的退单表,看这个叫order。这单表啊,这个要注意一下,好,那接下来呢,是我们的评价啊,评价数据就因为点S。然后这边还是一样的麦克YouTube,然后评论group加得到一个comment。对吧,好,那这块呢就搞定了,我们总共呢有这七个流,接下来呢,我们就要加工这七个流,把它变成一个统一的数据格式,对吧?统一的数据格式OK,那这个呢,是思路的一个,在整理加消费数据创建流对吧?这个呢是比较简单的,无非就是说看着挺吓人啊,因为流比较多嘛,对吧。
我来说两句