140_尚硅谷_CDH数仓_Oozie任务编写及运行

好，接下来呢，我们开始具体的去做这个无人任务啊，那首先呢，我们要在这个满时候当中生成对应的数据，那这里面呢，我们生成2月12号的数据，那这块把它复制过来。拿到这个这个售药。好，执行这个脚本，生成对应的数据。哎，这样的2月12号的数据，你看一下打开。诶，这里面呢，就有2月12号的数据了啊，首先把这数据准备好，接下来这里面呢，是安装UZ的一个可视化，那这个呢，你可安装可不安装，那这里面呢，我就先不安装它了啊，直奔这个主题，在hell查看hall的外部界面啊，进到这里面，然后编写对应的5G任务流，好，我们来做一下。来到这里面，诶，点击query，下面这有一个work floor进来。哎，OK，那这样呢，我们就来到了这个页面，好，首先呢，我们改一下这个my flow啊改个名字，我们这个呢，跑的任务呢是GMV，那我就起个名字叫建V。

保存一下啊。MV，然后点击OK，那这样的这个名字我们就要记好了啊，然后呢，点击这个保存啊，一定要先保存OK。啊，配置saved。搞定，保存完这个页面之后啊，接下来我们继续往下看啊，啊首先呢是创建这个JV，点击保存之后呢，就可以编写具体的任务脚本啊，并将这个脚本呢上传到ADS，那这里面说的这个脚本是什么呢？其实就是我们之前写的它这个inport啊库inport，还有这个ODs.SH啊DWDSH就一层一层的这种导入导出脚本。啊，那这里面呢，其实这个脚本我们已经写好了，那我们就简单直接把我们以前的脚本给它上传上来就OK了，那这里面要想上传脚本呢，我们就点击这个worklo work space。

哎，上传上传到什么位置呢？你把它上传到。好。一会呢，我们把它上传到对应的这个位置上，那我们的这个脚本在什么位置呢？来到这个linu虚拟机。WD，哎，我们的脚本呢，就在下面这些位置，把这些脚本通通都上传上去啊，其实我们要用到的有这么几个，呃，有这个导入啊，然后呢，之后呢是ods ods之后DWDDWD之后是DWS，再之后呢，就是ADS，一层一层的导啊，然后之后呢，还有一个啊导出哈，啊先导入再导出，OK，把这些脚本上传。

上传的命令的是嗨，Do FS，嗯，上传。FS杠。put上传的内容在。目录下啊，来一个星，就是把所有的脚本都上传上去啊，然后这个位置上。OK，上传成功了，那我们看一下这个路径上有没有哈，一定要确认一下。来到集群。As。啊OK，你这一看一查看呢，这里面就有对应的这个脚本通通都上传上来了啊一会儿呢，我们就关联一下这个脚本啊，配置一下它相应的这个执行顺序啊好，那也说现在呢，已经上传成功，上传成功之后点击右侧的这个documentation啊，然后键位那这个地方在哪呢。

来到he点它。然后点击documentation。点击我们刚才创建的键。哎，这样呢，就有了一个初步的一个任务，那这个任务呢，我们需要去编写一下，那点击这个编辑啊编辑，那这个编辑这个任务啊，怎么来做呢。这点。把它点成actions啊，这样呢才能够操作啊，一定要点成成actions之后，下面开始操作，诶点击这个cell，因为我们调用的是cell脚本，往这一拖。啊，那我们第一个执行的脚本是哪一个脚本呢。我们要找一下哈，这里面。What's this？Li，哎，就是我们刚才上传的这些cel脚本，那我们第一个使用的就是SCO import，好，点击添加进来了，添加完这个脚本之后，别忘了这块还有一个file斯这块呢，也要添加一下。

刚才我们添加的这个port这个啊，也就这两处添加的内容一模一样啊，但是你都要添加，但是呢，我们在执行这脚本的时候呢，其实它是有输入的参数了，比如说我们这个schoolport的，它就有两个参数，第一个参数是什么呢？Girl。啊，第一个参数就是二，那它还有一个第二个参数，那第二个参数就是我们传入的参数是2019杠零二杠幺二啊2月12号。当然我们现在呢，是采用这种写死的方式啊，直接传进去了，如果你想灵活的去设置对应的这个参数变量值，你这块可以写成什么呢？啊，你可以写成这个刀勒符。对应的。哎，比如说都。Date啊这种方式也行，那只不过呢，现在呢，我这个为了这个方便啊啊就不这么做了啊，直接把这个啊写死了，当然你后面要会的时候，要这个真正开发的时候可以改成那种方式哈，好，那我们第一个脚本就做完了。

啊，也就是说第一个导入数据，那下一个执行完这个任务，要执行什么任务呢。要执行的就是ods任务。我。Ods。在这呢，嗯，然后添加之后呢，再添加发文件。仍然添加的是ods。之后添加这里面的参数，那这个参数呢，它是其实是时间啊，2月12号再继续。下一个任务。嗯，一拖转下一个任务是哪一个呢？Ods之后就到了这个DW。DWD结束之后再添加。再添加一下dwd OK，它对应的参数。2月12号搞定这个完成之后就来到了DWS。

OK，我们再拖一下哈，再拖一下，缩小一下这个页面。OK。来一下DWSDWS在。这个嗯，好嘞。OK，然后再选择一下DWS。DW。S。OK之后添加对应的参数。2月12号啊，DWS之后就到了最后一层ADS层。拖拽一下。哎，那我们再来一下哈。啊，缩小一下。它这个页面啊，不是特别友好哈。再来。

哎呀。好，那这个里面我们选择的是。ADS层最后一层啊，OK。没选择上是吧，那我们再来一下。ADS。OK，那这样的ods这个有了，那我们在添加一下ods文件。ADS。参数。2月10号2月12号，那这个ADS结束之后，就到了最后一个脚本啊，最后一个脚本胜利在望。OK好嘞，那最后一个就是这个导出。之后我们添加导出。

好，那这里面要注意一下，它这个参数就不是时间了，它是二啊二的参数，而且变一个参数，那这样我们就写完了这个正常的这个任务调度，那这里面这个调度这个规则呢，就是先执行它，执行它完成之后执行这个，再执行下面这个啊相应的有这个依赖关系哈，啊好，那别忘了一个保存。点击保存。啊，OK，保存完成之后，下面呢，我们就可以执行了啊，可以执行，我们点击执行。提交。哎，这样呢，他就开始去执行我们这几个赛脚本的任务啊，OK哈，这里面需要等待的时间，呃，很长，大概将近20分钟到半个小时的时间。好，大概经过20分钟左右的时间，那这个呢，我们整个这个物类调度流程调度啊，我们就完成了，也就是从这个呃，把这个买车的数据导入到adys，并把adys数据导入到ods层OS到dwddwsads以及到s school啊这个整个这个调度过程啊，跟我们之前学的这个阿斯卡班是一模一样的啊，所以这里面呢，我就不再赘述了哈，呃，这个步骤呢，相对来说啊多一些，那后面呢，要认真去挑就OK了哈。