00:00
那我们接下来做一个案例啊,从circle server读取数据,插入到HDFS。那我们首先来瞅一眼。并看一眼模板啊,PY-2CIRCLE server。ER-w hdfs writeer,那writeer就不用看了,老生常谈啊,那前面这个大家发现没有,是不是也是一个连接选项,一个JDBC,一个table对吧,然后呢。用户名密码,那肯定还可以写一个什么列名currents对吧,这个就是关系型数据库的一个基本模板啊,那这个咱们直接拷贝案例啊。比较长啊,所以不想挑啊。呃,这个得改一下啊,Circle server reader。
01:02
对吧。社哦,文档忘了改了。好了,呃,接下来你看参数呢,指定一个列名,指定一个连接选项,指定一个表明。呃,指定用户名密码,但是我这个用户名密码是不对的啊,应该是sa,然后呢,1234QW1啊,那这边唯一的区别在哪呢?在这。JDBC的写法啊。那它是什么呢?JDBC冒号circle server,然后呢?Ipn端口,它的端口默认是1433啊,如果你的防火墙把它关了,你记得把它打开,或者把防火墙关了。
02:00
不会解决问题就解决提出问题的人对吧?那数据库的名字它并不是用斜杠来拼接的,它是以参数的方式啊,用分号隔开,然后data name等于什么对吧?等于电脑插是我之前创建的啊,我装在哈度二没毛病啊,19点的这张表没毛病啊,HDFS呢没毛病。两个字段,然后这边改一下。8020呃,分格服务随意啦,用等号呗。SERVER0TST追加。并发为一,好,没毛病啊。I'job呃,Circle server two HD FS点。接下来就执行了。B贝塔差点PY。呃,Job circle server。
03:02
To h DFS。应该好了,我们来瞅一眼吧,跟目录下面啊,先刷新一下页面啊。你看这里是不是过来了?它的用法跟MY搜狗没有太大区别啊,基本一样啊,我们可以点一下头页。挂机对吧,分隔符是等号啊。这个相信没啥问题啊,没啥问题,那我们接下来试试导,从circle server导出到MYSQL啊,那这个呢,咱们就没有什么。再去说了,这两搜狗server的reader咱们也都看过了,买搜狗的writer咱们也写过很多次了。我直接拷过来改一改。呃,列名没毛病,JDBC也没毛病,库明啊这个。
04:02
好,这个用户名密码得改1234Q5W12WRITE呢my circle writer哈杜13306DATA叉student。我们是有一个data差的库,对吧,也有个student,密码是呃,用名密码对了,插入。速率为一,好,没毛病啊。你跑过来YM跳吧。Circle server to my circle again。我们先提前进来看一下啊。Use data差。哎,不用我直接是不是就在这里啊。对吧?From student,这是my circle啊,之前有这么几条数据。
05:04
我们执行一下PY,然后呢,Job circle server my circle。回车。好,应该已经好了,我们直接过来看吧,不等他统计了回车,那么大家可以看到啥呀?Circle server里面的这条数据已经过了,怎么样,是不是很灵活对吧?对了,仓。这个大家去玩一玩就行,那如果还想知道其他参数怎么办?去get HUB上面点开对吧,有一些参数可以指定,你就可以去上面看啊。
我来说两句