尚硅谷大数据技术之Airflow/视频/12_airflow配置邮件报警功能.mp4原创

好，最后一步啊，我们在使用调度器的时候呢，不仅仅是希望他能够自动一点啊，像个这个人工智能女朋友一样啊，帮我们做一些我们不想去做的事情啊，并且呢，他很准确，很很定时，对吧？这只是一方面啊呃，另一方面呢，我们还有一个想法就是说，诶，你不能只会干活对吧，你要变得机灵一点是吧，像一个秘书一样啊，什么叫秘书呢？诶有什么问题咱得向我汇报对吧，你不能说出了错了就让他错着，错着那肯定不行，你得汇报啊，那我们的air floor呢也一样啊，满足你的各种服务需求啊，这里呢，我们就把这个邮件服务器给他打开，呃，如果你想使用这个邮件服务器呢，首先你要有一个邮箱啊，你的这个邮箱呢，要能够使用这个SMTP的这么一个功能啊，这个功能呢啊，你可以到网上去搜啊，都是能够找得到的啊，这边我就不登录了啊，你进入到邮箱之后呢，你点击设置啊，这里面常规常规里面要。

把SMTP这个功能呢，给它打开，打开之后要去点击下面这个生成授权码啊，生成授权码，这个生成授权码呢，会让你的手机去发一个验证码啊，发完验证码之后，它给你一个密码，注意了，这个密码不是你邮箱的密码啊，不是邮箱的密码，就是一个特定生成的一个乱码啊，我已经操作过了，我的乱码呢，就是这一行啊，这个乱码呢，你只要生成完之后，你别点删除啊，它就是一直可以去使用的，那首先呢，我们要给我们的air flow框架去配置它的一个发件的一个邮箱啊，就是你自己的邮箱，你不是要发出去嘛，你要给air floor配一个发件的邮箱，这个发件的邮箱呢，写到air flow的配置文件里面啊，我们来去写一下。叫VM标号杠，Air floor a floor.cfg好在最后的位置啊，我们随便找一个地方啊，呃，当然你你你你找一个这个，呃，对应的这个标签啊，也是可以的啊，你可以自己写一个这个啊对应的标签啊，它这个标签呢，就是email嘛，对吧，冒杠。

嗯啊好，找到这个email里面啊，也是可以的啊，你写到最后啊，它也是可以的啊好，它这个email里面呢，它对应这边会告诉你啊，他一些默认的一个参数啊，这些参数呢都啊没法用，说实话，因为你没有配置这个具体的邮箱嘛，对吧，来给它改一下啊呃，改的内容呢，就是我们这些啊CTRLC。好在这边我们给它粘贴过来啊。粘贴。对吧，好，这个上面的内容呢，都可以去，不用管它啊，你只要写到它的下面啊，这就可以了啊好，我们保存退出啊，写完了之后呢，需要去重启一下你的air flow啊，不然呢，这些配置参数呢，它不会生效啊，重启一下啊，到这边af.stop。好，af.start。

好，重启完成，重启完成之后呢，我们接下来来修改我们的test.python啊这么一个文件，修改它的内容呢，就让他支持啊，发送一个邮件，我们来看一下修改之后的内容啊。好，来到这边VM啊，叫test.python啊，到最开头的地方啊，一大G啊D100D啊都给它删掉，删掉之后把这个新的内容给它粘过来。啊CTRLC啊给它粘贴过来好保存退出，粘贴过来之后呢，来给大家介绍一下啊，发的这个内容呢，是哪些东西啊呃，我给它放到这个地方啊，再来一个C位，好，我们改了哪些东西呢？这个对比前面首先第一点把这个给打开了。啊，说新导了一个依赖啊，你要导入这个email的一个依赖，不知导赖的话呢，等一下它会报找不到啊，那后面这个地方呢，出错是否发邮件啊，你可以根据自己的需求自己来设置，其实你即使不出错也可以让他发邮件的，因为再往下的地方，你可以设置一个email的operator算子嘛，Email的一个算子啊，这个email的算子呢，你设置到最后发送啊，最后发送，最后发送的内容，哎，给它写成一个大标题的一个格式啊，写一个test的模式就可以了，它这里面有一个to，有一个抄送啊，To就是发送给啊，那抄送抄送给谁，你这里写上你对应的邮箱啊就可以了啊，我应该是这个啊，想要你对应的一个邮箱啊就就就可以了啊。

好，你邮箱写不对也没有关系啊，他邮箱写不对，它会发送不出去，再给你退回来的，本来我们也是只是一个测试啊，好，你改完了之后啊，你文件也改完了啊，你的air flow也已经重启了，那接下来呢，你可以到这边来去刷新来去看一下啊呃，你首先找到你对应的这个test任务啊，然后点进来之后呢，点击这个代码，代码里面就可以直接看，直观的能够看到啊，它到底有没有改过来，你可以看到，诶已经改过来了啊，支持动态修改嘛，好改完了之后呢，我们再来点击。

运行啊，让它运行起来。好，点击运行之后呢，它就开始去跑了啊，开始去跑了，这地方还有一个细节，就是我们这里的开始时间啊，写的是两天前啊做文档时间呢，跟录视频的时间有一点延迟啊，是两天前，那么它在运行的时候呢，他其实会补补这个任务啊，就是把之前呢也给它去运行一下啊，所以你可以看到啊，它在具体运行的时候，你看它是运行了28的，29的和30的啊，它运行了多个是吧？啊运行了多个，你看它这边运行的时候，二十八二十九啊，它会运行多个啊，那导致呢，它稍微有那么一点点，呃，比较慢，对吧，咱们稍微等一下啊。好，也可以到这边呢，去监控它一下啊，Test监控。好，对应这边呢，可以看到啊，三个都是葱绿色的啊，都是在运行当中是吧？这个第一个任务里面呢，它已经是运行了两个了啊，因为我们用的是本地调度器，它支持多并发，我们这三天的是任务呢，其实是呃一起在运行的，看到对吧，2829啊，这是29号30号和啊一号对吧，三个时间，它因为隔一天调度一次嘛，我们开始时间是28号，那就意味着29号运行一次，30号运行次跟一号运行一次，它三个任务是一起跑的啊导致呢，它速度呢，稍微慢了一点啊，那对于我们的雅恩，它也是一个这个对应的一个资源的一个调度，对吧？啊就是可以看到它是一个多并发的。

好，稍微等待他一下啊，他不跑到最后一层，他发送不出去啊。你查看这个D也能看得到，对吧，它是先DWD，再DL再ADS，最后发送email啊，那最后再发送，我们需要等待它一下。好，发送的这个email长什么样呢？我们去登录一下邮箱啊，就可以看得到了啊，这个就是你刚才对应注册的这个邮箱啊，QQ邮箱。

QQ。邮箱。好，这边呢，输入一下啊。好，还得用手机去验证一下啊，现在这个安全程度都比较高。邮箱我已经登录完成了啊，它这个地方呢，一直显示没有发送成功啊，可能我们的配置文件呢有点问题啊，那对应的邮箱里面呢，也没有收到邮件啊，我们再去检查一下啊好，VM执行啊呃，检查完之后呢，来去看一下啊，就是它的位置呢，其实就在我们刚才填的这个参数的下面啊，就是我们填写参数的位置呢，其实不对啊，我们来去给它改一下。

应该是在100，我就说了，你每次要填的时候呢，最好填到末尾的位置啊，你这没有填到末尾呢，导致它正确的地方呢，在它的下面啊，改错地方了，我们来把之前的内容呢给它删掉啊，第6D啊，然后DDDDDD。好，删掉之后呢，在下面这个位置啊，在这呢SMTP啊，对着这个参数呢，就给改一下，你也可以不改啊，直接把原先的给删掉，然后把你需要填的内容给它粘过来就可以了啊。好，我们来去重新粘一下CRC。这地方呢，给它删掉啊。好，最后两个参数呢，是调参数啊，这个可以不删啊，好一下点了两次啊，重新粘好给它填到对应这个位置啊就可以了啊，我们保存退出啊，这时候呢，再重新启动一下啊，这任务呢，还得重新跑啊叫af.stop。

AF start。好，对应这边呢，我们刷新啊。呃，刷新完之后呢，它可能是我们启动停止太快了啊，导致呢，它并没有停下来啊，我们重新启动一下啊，这边呢，给它删除一下。好，删除了之后呢，再等待一段时间啊，刷新一下，它在出来之后呢，再启动啊就可以了。好，我们也可以去监控它啊，它又重新跑了一下啊，把参数呢写到对应的位置啊，它就可以去发送这个对应的邮件了。好，等待一段时间之后呢，也可以看到啊，它这个邮件呢，就绿了啊，写的success啊，其实它并不一定能发送成功啊，我们来看一下好这边啊它就有了啊，首先你发的这个邮件呢，它这个目标路径邮件写错了，不存在啊，但是呢，因为我们设置的有操送啊，那操送的这个呃东西呢，倒是正确的啊，操送内容呢就发给你了，对吧？啊，你只要写对了地址这个邮件。

肯定是可以发送出去的啊，发送然后这是抄送，抄送给我自己了，他就可以看得到了，好，这就是我们对应邮件的一个填写啊，只要把参数呢填到对应的位置啊，你填到最后也行啊，填完了之后呢，呃，脚本里面给它加上这个email的一个operator啊，就可以进行一个对应的一个文件发送了啊。