关于 AWX 执行 ansible 的原理不解的地方 - V2EX
V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
firejoke
V2EX    Ansible

关于 AWX 执行 ansible 的原理不解的地方

  •  
  •   firejoke 2021 年 11 月 4 日 2278 次点击
    这是一个创建于 1552 天前的主题,其中的信息可能已经有所发展或是发生改变。

    最近一直在写一个给小白用的运维工具,使用 django+ansible 。
    红帽本身有一个这样的项目,收费的是 Tower ,开源的版本叫 AWX 。
    既然有现成的,就想看看他是怎么做的。

    首先因为 ansible 核心功能 play 是基于文件和 role 目录来执行可复用的任务,而目标机器组( inventory )也是记录在文件内的。
    最简单办法,就是文件读取和解析,然后映射到界面上,但这其中还涉及 play 文件内的各种变量和关键词,还有频繁的文件操作,不认为是一个最佳的解决方案。 比较合理的办法,是自行开发 ansible 模块或插件,以实现从你的 web api 获取资源。


    inventory 的解决办法比较简单,写一个 inventory 插件,从你的 api 接口获取主机列表,然后组装成 ansible 能识别的数据结构,实际上 AWX 的源码里也是写了这样的插件InventoryModule(BaseInventoryPlugin)
    这个插件使用了 awx 写的另一个 module_util:ControllerModule(AnsibleModule),用来从他的 web api 里获取资源。

    ... module = ControllerAPIModule(argument_spec={}, direct_params=module_params, error_callback=handle_error, warn_callback=self.warn_callback) ... inventory = module.get_endpoint(inventory_url, data={'hostvars': '1', 'towervars': '1', 'all': '1'})['json'] 

    而 play 的执行,awx 则是使用了ansible-runner这个库,这个库可以通过读取一个固定结构的目录直接执行 play ,也提供 python 接口可以传递 play 的必要参数来执行 play 。
    awx 是让用户自行提供一个 play 文件,然后保存到固定的目录下,inventory 也是保存到固定位置的文件里,然后调用 ansible-runner 执行。

    params = { 'ident': self.instance.id, 'private_data_dir': private_data_dir, 'playbook': self.build_playbook_path_relative_to_cwd( self.instance, private_data_dir ), 'inventory': self.build_inventory(self.instance, private_data_dir), 'passwords': expect_passwords, 'envvars': env, 'settings': { 'job_timeout': self.get_instance_timeout(self.instance), 'suppress_ansible_output': True, }, } ... if isinstance(self.instance, SystemJob): res = ansible_runner.interface.run( project_dir=settings.BASE_DIR, event_handler=self.event_handler, finished_callback=self.finished_callback, status_handler=self.status_handler, **params, ) ... 

    这个 task 的执行是通过 Job 模型保存时的信号来决定,task 的执行是维护在另一个线程内(这里还没摸透,只大致知道是通过信号引发执行)


    不解的地方在于:

    1. 既然已经写了一个 Inventory 插件,为什么这里还要把 inventory 保存到文件内呢?
    2. 为什么不把 play 以及 task ,role ,handler ,block 这些 Play 里的功能也设计成模型保存到数据库里呢?而是要用户自己写?
    4 条回复    2021-11-05 16:18:14 +08:00
    julyclyde
        1
    julyclyde  
       2021 年 11 月 5 日
    1 保存的是“这一次”执行的 inventory ,在 play 比较长的时候可以保证前后一致。要不然执行一半的时候上有 inventory 列表更新了咋办?
    firejoke
        2
    firejoke  
    OP
       2021 年 11 月 5 日
    @julyclyde #1 在 inventory 插件里,也是只从 api 里获取一次,中途不会在执行这个动作,所以不存在这个情况。
    julyclyde
        3
    julyclyde  
       2021 年 11 月 5 日
    @firejoke 存档
    firejoke
        4
    firejoke  
    OP
       2021 年 11 月 5 日
    @julyclyde #3 嗯,按这里 ansible-runner 调用方法来看,是根据指定根目录的目录结构来执行一个任务,可以认为是为单一指定的 project 保存一个 inventory 存档,这样就能理解。
    但为了这个目的的话,专门为这个 project 建一个 inventory group 不就行了,不管整个 inventory 怎么更新,只要这个 inventory group 不变就行了,每次执行这个 project 都使用这个 group 。
    关于     帮助文档     自助推广系统     博客     API     FAQ     Solana     4269 人在线   最高记录 6679       Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 34ms UTC 09:32 PVG 17:32 LAX 01:32 JFK 04:32
    Do have faith in what you're doing.
    ubao msn snddm index pchome yahoo rakuten mypaper meadowduck bidyahoo youbao zxmzxm asda bnvcg cvbfg dfscv mmhjk xxddc yybgb zznbn ccubao uaitu acv GXCV ET GDG YH FG BCVB FJFH CBRE CBC GDG ET54 WRWR RWER WREW WRWER RWER SDG EW SF DSFSF fbbs ubao fhd dfg ewr dg df ewwr ewwr et ruyut utut dfg fgd gdfgt etg dfgt dfgd ert4 gd fgg wr 235 wer3 we vsdf sdf gdf ert xcv sdf rwer hfd dfg cvb rwf afb dfh jgh bmn lgh rty gfds cxv xcv xcs vdas fdf fgd cv sdf tert sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf shasha9178 shasha9178 shasha9178 shasha9178 shasha9178 liflif2 liflif2 liflif2 liflif2 liflif2 liblib3 liblib3 liblib3 liblib3 liblib3 zhazha444 zhazha444 zhazha444 zhazha444 zhazha444 dende5 dende denden denden2 denden21 fenfen9 fenf619 fen619 fenfe9 fe619 sdf sdf sdf sdf sdf zhazh90 zhazh0 zhaa50 zha90 zh590 zho zhoz zhozh zhozho zhozho2 lislis lls95 lili95 lils5 liss9 sdf0ty987 sdft876 sdft9876 sdf09876 sd0t9876 sdf0ty98 sdf0976 sdf0ty986 sdf0ty96 sdf0t76 sdf0876 df0ty98 sf0t876 sd0ty76 sdy76 sdf76 sdf0t76 sdf0ty9 sdf0ty98 sdf0ty987 sdf0ty98 sdf6676 sdf876 sd876 sd876 sdf6 sdf6 sdf9876 sdf0t sdf06 sdf0ty9776 sdf0ty9776 sdf0ty76 sdf8876 sdf0t sd6 sdf06 s688876 sd688 sdf86