尚硅谷大数据技术之Airflow/视频/09_修改本地执行器多线程调度.mp4原创

好，我们除了修改它的数据库之外呢，还要修改一个东西叫执行器啊，在官方这个地方也给大家有推荐，他说呢不要使用这个顺序的excu执行器，在生产环境当中，这其实也很好理解啊，它除了这个顺序的执行器还有哪些呢？还有一些K8S的执行器，还有一些呢，本地的一个执行器，它这个顺序执行器呢，就有点像是一个队列啊，单进单出啊，影响它的一个任务调度啊，你在这边点开始的时候单进单出啊也不好，这里呢，我们可以去给他改一下，你也可以在这边再新开一个，可以看到它的一个官网，他说了你可以去使用在号这个标签下面去修改这个EXQ，你可以去使用官方提供的K8S的这个XQ，也可以去自定义这个XQ，那这里我们就不自定义了啊，因为呢，它只是一个任务的一个调度啊，你只要不是单进单出的啊，能够多个任务一起调度都是没有问题的，我们就。

给它修改成一个本地的调度器就可以了啊，也来去修改一下，好在这边呢，我们VM啊，是在这个a flow的配置文件里面啊，A floor a floor啊。点CFG，好在这个里面呢，我们找到对应的XQ啊，它其实在Co里面啊，直接查靠也行。嗯，写N啊，N就是下一个。好像是啊，在最上面啊，有一个car car呢，你往下翻往下翻啊，它这个地方就有ex，这个ex里面有KY啊有这个我们使用的这个顺序的，还有本地的，还有一些别的啊，就使用这最简单的，就用本地呢去创建一个执行器就可以了。好。这边我们执行啊，如果只是几百个任务的话呢，因为本地的它完全处理的过来啊，毕竟呢，它只是管一个任务的一个调度，对吧？好，我们来保存内出。好了，那这里呢，我们所有的东西就已经改完了啊，改完了之后呢，我们来重启airflow啊，叫这边来啊af.stop用我们的脚本啊，然后af.start。

好，重新启动，因为我们重新初始化了，所以里面的内容呢，重新跑了一遍。好，已经启动完成了，我们再来看啊刷新。好，看一下是哪里出了问题啊，呃。我看一下叫杠EF啊，管道符g Rep floor。嗯。哦，它这里面嗯，没有启动web server是吧，我们重新来执行一下啊。

好，我们再重新启动一下啊，刚才呢，这个脚本呢，它掉的时候可能前后电延迟啊，它没有启动这个web serve啊，再启动一下就可以进来了啊进来之后呢，你可能想着A只重启一下，再输入之前的密码啊，你来登录你会发现又报错了啊，这是因为呢，你把后台的这个库给他更改了，所以你在使用之前的账号密码已经不行了，其实我们刚才这个操作相当于什么呢？就相当于啊江湖当中已经失传的删酷跑路啊，你已经删库了，对吧？那这时候呢，你要么呢把数据呢在员工中的造一遍啊，要么就可以准备跑路了，对吧？好，我们再找到之前的啊创建这个用户名的一个方法啊，再来去执行一下啊，CTRLC。代表我们到这个地方啊，粘贴好对应地方创建一个userr啊叫阿达me，然后密码呢，是123456回车啊，123456回车，好已经重新创建完成了，再到这边呢，再来输入登录，好已经登录完成了，你看你再登录官方就不给你说一些建议了，就是因为我们已经正确使用了啊，已经正确使用了，好这就是我们的AR。