资讯专栏INFORMATION COLUMN

利用Python实现自动化监控文件夹完成服务部署

89542767 / 573人阅读

  小编写这篇文章的一个主要目的,主要是来给大家做一个介绍,介绍的内容是关于Python的,比如说,利用Python实现自动化监控文件,并把这些文件部署在服务器上面,具体的部署过程,下面给大家做个解答。


  大家好,我是安果!


  最近在部署前端项目的时候,需要先将前端项目压缩包通过堡垒机上传到应用服务器的/tmp目录下,然后进入应用服务器中,使用mv命令将压缩文件移动到Nginx项目设定目录,最后使用unzip命令解压文件,以此完成项目的部署


  仔细分析,大部分操作都是重复性的动作,人工去完成这些操作会大大降低工作效率


  本篇文章将介绍如何利用Python监控文件夹,以此辅助完成服务的部署动作


  1.准备


  这里要介绍一个Python依赖库「watchdog」


  它可用于监控某个文件目录下的文件变化,包含:删除、修改、新增等操,每一个操作都会回调一个事件函数,我们可以在内部编写自定义的逻辑,以此满足我们的需求


</>复制代码

  1.   #安装依赖包
  2.   pip3 install watchdog


  2.实战一下


  首先,我们需要创建一个监听器,用于监听文件夹目录


</>复制代码

  1.   from watchdog.observers import Observer
  2.   ...
  3.   #创建一个监听器,用来监听文件夹目录
  4.   observer=Observer()
  5.   ...


  然后,创建2个事件处理对象


  PS:该对象继承于「FileSystemEventHandler」类


  它们分别用于监听「/tmp」目录、「/home/project/frontend」目录,假设事件对象被命名为obj1、obj2


  obj1负责监听/tmp目录,重写「新建或修改」事件方法,完成压缩文件的移动操作


</>复制代码

  1.   from watchdog.events import*
  2.   import ntpath
  3.   import shutil
  4.   import zipfile
  5.   def get_filename(filepath):
  6.   """
  7.   根据文件夹目录,获取文件名称(待后缀)
  8.   :param filepath:
  9.   :return:
  10.   """
  11.   return ntpath.basename(filepath)
  12.   class FileMoveHandler(FileSystemEventHandler):
  13.   def __init__(self):
  14.   FileSystemEventHandler.__init__(self)
  15.   ...
  16.   #文件新建
  17.   def on_created(self,event):
  18.   #新建文件夹
  19.   if event.is_directory:
  20.   #print("directory created:{0}".format(event.src_path))
  21.   pass
  22.   #新建文件
  23.   else:
  24.   #print("file created:{0}".format(event.src_path))
  25.   filename=get_filename(event.src_path)
  26.   #如果属于前端的4个项目压缩包,开始文件夹的操作
  27.   if filename in watch_tags:
  28.   self.start(filename)
  29.   ...
  30.   def on_modified(self,event):
  31.   if event.is_directory:
  32.   #print("directory modified:{0}".format(event.src_path))
  33.   pass
  34.   else:
  35.   #print("file modified:{0}".format(event.src_path))
  36.   filename=get_filename(event.src_path)
  37.   if filename in watch_tags:
  38.   self.start(filename)
  39.   ...
  40.   def start(self,filename):
  41.   """


  文件处理逻辑


</>复制代码

  1.   :param filename:
  2.   :return:
  3.   """
  4.   try:
  5.   #文件名不带后缀
  6.   filename_without_suffix=filename.split(".")[0]
  7.   #源文件路径(压缩包文件)
  8.   source_file_path=watch_folder+filename
  9.   #目标文件路径(压缩包文件)
  10.   target_file_path=target_folder+filename
  11.   #目标项目文件夹(目标项目)
  12.   target_project_path=target_folder+filename_without_suffix
  13.   #1、复制文件到目标文件夹
  14.   print(f"拷贝源目录{source_file_path},目标文件夹:{target_folder}")
  15.   #删除目标文件夹下的压缩文件
  16.   if os.path.exists(target_file_path):
  17.   os.remove(target_file_path)
  18.   #移动文件到目标文件夹中
  19.   shutil.move(source_file_path,target_folder)
  20.   #2、清空目标文件夹中内的所有文件夹(如果存在)
  21.   #如果不存在,新建一个文件夹
  22.   if os.path.exists(target_project_path):
  23.   shutil.rmtree(target_project_path,ignore_errors=True)
  24.   print(f"项目{filename_without_suffix}移动成功!")
  25.   except Exception as e:
  26.   print("部署失败,错误原因:",str(e.args))


  obj2负责监听/home/project/frontend目录,同样重写「新建或修改」事件方法,完成压缩文件的解压动作


</>复制代码

  1.   ...
  2.   def start(self,filename):
  3.   #文件名不带后缀
  4.   filename_without_suffix=filename.split(".")[0]
  5.   #目标文件路径(压缩包文件)
  6.   target_file_path=target_folder+filename
  7.   #目标项目文件夹(目标项目)
  8.   target_project_path=target_folder+filename_without_suffix
  9.   r=zipfile.is_zipfile(target_file_path)
  10.   if r:
  11.   fz=zipfile.ZipFile(target_file_path,'r')
  12.   for file in fz.namelist():
  13.   fz.extract(file,target_folder)
  14.   else:
  15.   print('这不是一个正常的zip压缩包!')
  16.   ...


  接着,通过监听器启动上面两个事件的监听任务


</>复制代码

  1.   import time
  2.   ...
  3.   if __name__=="__main__":
  4.   #待监听的文件夹目录
  5.   watch_folder="/tmp/"
  6.   #项目目标文件夹目录
  7.   target_folder="/home/project/frontend/"
  8.   #监听文件夹名称,即:项目压缩包名称
  9.   watch_tags=['proj1.zip','proj2.zip','proj3.zip','proj4.zip']
  10.   #创建一个监听器,用来监听文件夹目录
  11.   observer=Observer()
  12.   #创建两个事件处理对象
  13.   move_handler=FileMoveHandler()
  14.   unzip_handler=FileUnzipHandler()
  15.   #启动监控任务
  16.   #参数分别是:观察者、监听目录、是否监听子目录
  17.   observer.schedule(move_handler,watch_folder,True)
  18.   observer.schedule(unzip_handler,target_folder,True)
  19.   observer.start()
  20.   try:
  21.   while True:
  22.   time.sleep(1)
  23.   except KeyboardInterrupt:
  24.   observer.stop()
  25.   observer.join()
  26.   ...
  27.   最后,我们在服务器上通过「nohup」命令,让文件监听程序在后台运行即可
  28.   #在后台运行
  29.   #项目文件:watch_folder.py
  30.   #日志文件:watch_folder.log
  31.   nohup python3-u watch_folder.py&gt;watch_folder.log 2&gt;&1&


</>复制代码

  1.   #查看日志:
  2.   cat watch_folder.log


  3.总结


  通过上面的操作,每次我通过堡垒机将前端zip压缩项目文件上传到应用服务器的/tmp目录下,程序会自动进行后面的操作,自动完成应用部署


  综上所述,这篇文章就给大家介绍完毕了,希望可以给大家带来帮助。

文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。

转载请注明本文地址:https://www.ucloud.cn/yun/128358.html

相关文章

  • 到底什么是TAE

    摘要:回滚部署开发者每次部署的程序包会自动备份到历史版本,发布异常时,可以指定回滚部署到某一历史版本。网络方面采用了硬件防火墙设施,提供四层到七层的全面防护,防护类型包括等所有攻击方式,支持清洗和黑洞机制,还接入了防护等功能。 TAE2.0(Taobao App Engine)是针对移动互联网场景的定制化PaaS云服务,基于阿里云基础设施,采用Docker容器技术封装应用运行环境,并且针对互...

    novo 评论0 收藏0
  • 到底什么是TAE

    摘要:回滚部署开发者每次部署的程序包会自动备份到历史版本,发布异常时,可以指定回滚部署到某一历史版本。网络方面采用了硬件防火墙设施,提供四层到七层的全面防护,防护类型包括等所有攻击方式,支持清洗和黑洞机制,还接入了防护等功能。 TAE2.0(Taobao App Engine)是针对移动互联网场景的定制化PaaS云服务,基于阿里云基础设施,采用Docker容器技术封装应用运行环境,并且针对互...

    yankeys 评论0 收藏0

发表评论

0条评论

89542767

|高级讲师

TA的文章

阅读更多
最新活动
阅读需要支付1元查看
<