00:00
好,那接下来呢,我们做一个整体测试啊呃,那首先我们还是开启这个弗林格CDC,这个时候呢,可以从弗林CDC开启了,注意,呃,那由于我们维度信息已经导进去了,所以呢,我再改回latest,历史数据我就不读了,每一次都读历史数据没有意义,对吧?所以呢,改成这个样子啊,然后呢,开启CDC。先把这个弗CC开起来啊,这个时候完全可以先开它了,反正我们消费的是latest数据对吧。好,那接下来呢,贝斯的DB也看一下。注意啊,第二次启动的时候,你可以把那个initial改为latest啊,没必要再是啊,就是同步一次就够了。好连接了,这个已经启动了,对吧,这一边同样的我们也等到它连接并打印我们的这个什么建表语句,对吧,它会打印建表语句啊,然后我们再去开启啊,当然这个时候开启没关系啊,开啊开是可以开的,对吧。
01:11
但是现在呢,不要着急造数据。这边哎,这表语句已经打印了,看啊,Base DB这表语句又打印了一次,因为每次都初始化嘛,对吧,好,那接下来呢,All we ABB。这边呢,应该也已经启动了啊,启动好之后呢,我们就可以造数据来做一个终极测试,对吧。这边我们稍微多等一会儿啊,因为这个不确定,它里边又要初始化与这个菲利X连接啊,又要去开辟连接值,做的事情还蛮多,所以我们多等一会儿啊,这会儿应该差不多了,来变形。嗯。
02:01
好,那这个呢,造完了,造完之后呢,我们先看数据啊,首先刷新,现在呢,这一次造的是46条数据。对吧,46条数据,好,那我们先看这个数据丢没丢啊。数据丢没丢,先是双流撞移之后的结果,46条没有问题对吧,在这啊。46条对吧,好,接下来我们看抓匀之后的数据也没有超时对吧,这个数据也接着打印了,然后我们看他有没有丢。他呢也是46条也没有丢吧,啊也没有丢,诶我们没有启动消费者去测试对吧?呃,那等会我们可以测一下,我们接下来检查一下数据对不对啊,数据主要看这个维度啊,看这个维度那省份是不是有了。对吧,省份的信息有了,用户信息有了,然后PU trademark category。是不是也都有了对吧,所有维度你看最后就行了,对吧,从省份开始看,所有的维度都关联上了,那这个就搞定了对吧?好这个就搞定了,好那这样我们再测一下这个卡不卡的,我刚才忘了开卡挂消费者对吧。
03:09
我们重新启动一下啊,重新启动呢,更好方便看数据,然后呢,我去开一个消费者来到这边来啊。克隆。CD到OD Mo到卡夫卡,然后呢,我们去拿一个卡夫卡的一个消费者,他的一个。命令,然后呢?名称我们的主题在这叫DWMY走一下啊好,这个已经开启了,开启之后呢,它也已经开启了,对吧,这边服务我们造数据就好。张书记。啊,刚才我们看到这个程序没有丢数据的,其实在这边等着他很快啊,他关联其实蛮快的,因为用的异步查询嘛,就不像之前那么慢了。开辟连接值之后立马就出来了,对吧?啊,一瞬间我们的数据几十条数据就瞬间出来了啊好,那这个时候我们检查数据丢没丢啊,首先刷新这一次是40条啊,40条数据先还是一样,我直接看这个就行了,对吧,前面就不看了,这个都是40条,那双零状语肯定是40条没问题,然后看检查一下数据丢没丢。
04:19
数据所有的维度都关联上了,对吧,随便看几条啊对吧,啊也没有超时,说明我们数据肯定都关联上了,没有问题,然后大家看这看卡不卡,卡不这数据也来了对吧?我怎么确认这个数据丢没丢呢?很简单,CTRLC。这一次消费了40条数据对吧,说明数据也没有丢,那这块就搞定了啊,咱们所有的东西都测完了对吧。
我来说两句