使用 ansible

分类：编程问答

如何解决使用 ansible

我们有一个包含数十台服务器的 Ansible 清单，每个微服务按服务器分组。假设我们的清单中有多个应用程序组，其中包含服务器。

说：

[group1]
server1
server2
server3
server20
server27
server38

[group2]
server4
server5

[group3]
server7
server8
server9
server6

此库存已用于数十场比赛，因此不能仅更改它。我需要处理这个设置。

我需要知道的是，是否有可能在每个组的一台服务器上并行运行一个游戏，而无需在剧中明确命名它们？ （组和服务器可以由其他人添加，我需要玩才能应付）

所以当播放开始时，它可能会在 server1、server4 和 server7 上并行处理。 server2 上的处理可能会在 server1 完成时开始，server5 的处理可能会在 server4 完成时开始，等等。我猜你明白我的意思。这意味着，一开始，每个组的一个服务器被处理，但随着时间的推移，较小的组将完成，而在较大的组中仍然会进行处理。

有没有办法实现这一点？

硫亚

解决方法

这里已经有一个关于如何在多个主机上运行剧本的答案Ansible: deploy on multiple hosts in the same time

也许你可以从那里开始形成。但是，如果您只对并行运行第一台服务器感兴趣，那将会更加困难，因为它需要编写自定义脚本或类似的东西

,

Q: "在每组中的 1 个服务器上并行运行...在服务器 1、服务器 4 和服务器 7 上并行处理。服务器 1 完成后，服务器 2 上的处理可能开始，服务器 5 的处理可能开始当 server4 完成时，等等......迭代编写代码时未知的多个组和服务器。"

A：作为一个不完整的提示，下面的剧本

- hosts: all
  gather_facts: false
  vars:
    _groups: "{{ groups.keys()|difference(['all','ungrouped']) }}"
#   _hosts: [0,1,2]  # Range of minimal common leght perhaps?
    _groups_len_min: "{{ _groups|map('extract',groups)|map('length')|min }}"
    _hosts: "{{ range(_groups_len_min|int) }}"
    my_hosts: "{{ query('cartesian',_hosts,_groups) }}"
  tasks:
    - add_host:
        name: "{{ groups[item.1][item.0] }}"
        groups: my_group
      loop: "{{ my_hosts }}"
      run_once: true

- hosts: my_group
  gather_facts: false
  serial: 3  # TODO: Number of the groups involved
  order: inventory
  tasks:
    - debug:
        var: inventory_hostname

给予

PLAY [my_group] ***************************************************

TASK [debug] ******************************************************
ok: [server4] => 
  inventory_hostname: server4
ok: [server1] => 
  inventory_hostname: server1
ok: [server7] => 
  inventory_hostname: server7

PLAY [my_group] ***************************************************

TASK [debug] ******************************************************
ok: [server2] => 
  inventory_hostname: server2
ok: [server5] => 
  inventory_hostname: server5
ok: [server8] => 
  inventory_hostname: server8

PLAY [my_group] ***************************************************

TASK [debug] ******************************************************
ok: [server6] => 
  inventory_hostname: server6
ok: [server3] => 
  inventory_hostname: server3
ok: [server9] => 
  inventory_hostname: server9

如果你想包括所有主机，用哑元填充缺失的主机，例如给定库存

shell> cat hosts
[group1]
server1
server2
server3

[group2]
server4
server5

[group3]
server7

剧本

- hosts: all
  gather_facts: false
  vars:
    _groups: "{{ groups.keys()|difference(['all','ungrouped']) }}"
    _groups_len_max: "{{ _groups|map('extract',groups)|map('length')|max }}"
    _hosts: "{{ range(_groups_len_max|int) }}"
    my_hosts: "{{ query('cartesian',_groups) }}"
  tasks:
    - add_host:
        name: "{{ groups[item.1][item.0]|default('dummy-' ~ ansible_loop.index) }}"
        groups: my_group
      loop: "{{ my_hosts }}"
      loop_control:
        extended: true
      run_once: true

- hosts: my_group
  gather_facts: false
  serial: 3  # TODO: Number of the groups involved
  order: inventory
  tasks:
    - name: Proceed if not dummy
      block:
        - debug:
            var: inventory_hostname
      when: inventory_hostname is not match('^dummy-\d*$')

给予

PLAY [my_group] *****************************************************

TASK [debug] ********************************************************
ok: [server1] => 
  inventory_hostname: server1
ok: [server4] => 
  inventory_hostname: server4
ok: [server7] => 
  inventory_hostname: server7

PLAY [my_group] *****************************************************

TASK [debug] ********************************************************
skipping: [dummy-6]
ok: [server2] => 
  inventory_hostname: server2
ok: [server5] => 
  inventory_hostname: server5

PLAY [my_group] *****************************************************

TASK [debug] ********************************************************
ok: [server3] => 
  inventory_hostname: server3
skipping: [dummy-8]
skipping: [dummy-9]

注意事项

一个简单的选择是创建动态组，例如

- hosts: all
  gather_facts: false
  vars:
    my_groups:
      my_group1: [[group1,0],[group2,[group3,0]]
      my_group2: [[group1,1],1]]
      my_group3: [[group1,2],2]]
  tasks:
    - add_host:
        name: "{{ groups[item.1.0][item.1.1] }}"
        groups: "{{ item.0.key }}"
      with_subelements:
        - "{{ my_groups|dict2items }}"
        - value
      run_once: true

- hosts: my_group1
  gather_facts: false
  tasks:
    - debug:
        var: inventory_hostname

- hosts: my_group2
  gather_facts: false
  tasks:
    - debug:
        var: inventory_hostname

- hosts: my_group3
  gather_facts: false
  tasks:
    - debug:
        var: inventory_hostname

给出（删减）

PLAY [my_group1] *******************************************************

TASK [debug] ***********************************************************
ok: [server1] => 
  inventory_hostname: server1
ok: [server7] => 
  inventory_hostname: server7
ok: [server4] => 
  inventory_hostname: server4

PLAY [my_group2] *******************************************************

TASK [debug] ***********************************************************
ok: [server5] => 
  inventory_hostname: server5
ok: [server2] => 
  inventory_hostname: server2
ok: [server8] => 
  inventory_hostname: server8

PLAY [my_group3] *******************************************************

TASK [debug] ***********************************************************

ok: [server3] => 
  inventory_hostname: server3
ok: [server6] => 
  inventory_hostname: server6
ok: [server9] => 
  inventory_hostname: server9

下一个选项是创建一个具有所需主机顺序的组并设置 serial 和 order，例如

- hosts: all
  gather_facts: false
  vars:
    my_groups:
      my_group1: [[group1,2]]
  tasks:
    - add_host:
        name: "{{ groups[item.1.0][item.1.1] }}"
        groups: my_group
      with_subelements:
        - "{{ my_groups|dict2items }}"
        - value
      run_once: true

- hosts: my_group
  gather_facts: false
  serial: 3
  order: inventory
  tasks:
    - debug:
        var: inventory_hostname

给出（删减）

PLAY [my_group] ****************************************************

TASK [debug] *******************************************************
ok: [server1] => 
  inventory_hostname: server1
ok: [server7] => 
  inventory_hostname: server7
ok: [server4] => 
  inventory_hostname: server4

PLAY [my_group] ****************************************************

TASK [debug] *******************************************************
ok: [server2] => 
  inventory_hostname: server2
ok: [server5] => 
  inventory_hostname: server5
ok: [server8] => 
  inventory_hostname: server8

PLAY [my_group] ****************************************************

TASK [debug] *******************************************************
ok: [server3] => 
  inventory_hostname: server3
ok: [server6] => 
  inventory_hostname: server6
ok: [server9] => 
  inventory_hostname: server9

为了避免手动编写大型矩阵的繁琐工作，可以动态创建结构，例如下面的播放创建了相同的动态组

- hosts: all
  gather_facts: false
  vars:
    _groups: [group1,group2,group3]
    _hosts: [0,2]
    _dgroups: [my_group1,my_group2,my_group3]
    _groups_hosts: "{{ query('cartesian',_groups)|
                       batch(_dgroups|length) }}"
    my_groups: "{{ dict(_dgroups|zip(_groups_hosts)) }}"
  tasks:
    - add_host:
        name: "{{ groups[item.1.1][item.1.0] }}"
        groups: my_group
      with_subelements:
        - "{{ my_groups|dict2items }}"
        - value
      run_once: true

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

相关推荐

matplotlib报错：AttributeError: module 'backend_interagg' has no attribute 'FigureCanvas'. Did you mean: 'FigureCanvasAgg'?
使用本地python环境可以成功执行 import pandas as pd import matplotlib.pyplot as plt # 设置字体 plt.rcParams['font.sans-serif'] = ['SimHei'] # 能正确显示负号 p
gitlab登录失败，报错：This challenge page was accidentally cached by an intermediary and is no longer available.
设置时间 控制面板
后端开发常见错误
错误1：Request method ‘DELETE‘ not supported 错误还原：controller层有一个接口，访问该接口时报错：Request method ‘DELETE‘ not supported 错误原因：没有接收到前端传入的参数，修改为如下 参考 错误2：cannot r
docker常见错误
错误1：启动docker镜像时报错：Error response from daemon: driver failed programming external connectivity on endpoint quirky_allen 解决方法：重启docker -> systemctl r
idea常见错误
错误1：private field ‘xxx‘ is never assigned 按Altʾnter快捷键，选择第2项 参考：https://blog.csdn.net/shi_hong_fei_hei/article/details/88814070 错误2：启动时报错，不能找到主启动类 #
pip安装依赖失败
报错如下，通过源不能下载，最后警告pip需升级版本 Requirement already satisfied: pip in c:\users\ychen\appdata\local\programs\python\python310\lib\site-packages (22.0.4) Coll
maven常见错误
错误1：maven打包报错 错误还原：使用maven打包项目时报错如下 [ERROR] Failed to execute goal org.apache.maven.plugins:maven-resources-plugin:3.2.0:resources (default-resources)
cloud项目中常见错误
错误1：服务调用时报错 服务消费者模块assess通过openFeign调用服务提供者模块hires 如下为服务提供者模块hires的控制层接口 @RestController @RequestMapping("/hires") public class FeignControl
springboot常见错误
错误1：运行项目后报如下错误 解决方案 报错2：Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:3.8.1:compile (default-compile) on project sb 解决方案：在pom.
springmvc拦截器中使用redisTemplate报空指针异常
参考 错误原因 过滤器或拦截器在生效时，redisTemplate还没有注入 解决方案：在注入容器时就生效 @Component //项目运行时就注入Spring容器 public class RedisBean { @Resource private RedisTemplate<String
vite报错：npm ERR! command C:WINDOWSsystem32cmd.exe /d /s /c C:UsersychenAppDataLocalTempnpx-dde1c848.cmd
使用vite构建项目报错 C:\Users\ychen\work>npm init @vitejs/app @vitejs/create-app is deprecated, use npm init vite instead C:\Users\ychen\AppData\Local\npm-
VM VirtualBox中安装centos时报错：设置基础软件仓库时出错
参考1 参考2 解决方案 # 点击安装源 协议选择 http:// 路径填写 mirrors.aliyun.com/centos/8.3.2011/BaseOS/x86_64/os URL类型 软件库URL 其他路径 # 版本 7 mirrors.aliyun.com/centos/7/os/x86
kafka常见问题
报错1 [root@slave1 data_mocker]# kafka-console-consumer.sh --bootstrap-server slave1:9092 --topic topic_db [2023-12-19 18:31:12,770] WARN [Consumer clie
hive常见问题
错误1 # 重写数据 hive (edu)> insert overwrite table dwd_trade_cart_add_inc > select data.id, > data.user_id, > data.course_id, > date_format(
装载数据时报错：Failed to execute spark task, with exception 'org.apache.hadoop.hive.ql.metadata.HiveException(Failed to create spark client.)'
错误1 hive (edu)> insert into huanhuan values(1,'haoge'); Query ID = root_20240110071417_fe1517ad-3607-41f4-bdcf-d00b98ac443e Total jobs = 1
flume常见问题
报错1：执行到如下就不执行了，没有显示Successfully registered new MBean. [root@slave1 bin]# /usr/local/software/flume-1.9.0/bin/flume-ng agent -n a1 -c /usr/local/softwa
hadoop集群常见错误
虚拟及没有启动任何服务器查看jps会显示jps，如果没有显示任何东西 [root@slave2 ~]# jps 9647 Jps 解决方案 # 进入/tmp查看 [root@slave1 dfs]# cd /tmp [root@slave1 tmp]# ll 总用量 48 drwxr-xr-x. 2
hive常见错误
报错1 hive> show databases; OK Failed with exception java.io.IOException:java.lang.RuntimeException: Error in configuring object Time taken: 0.474 se
Linux常见错误
报错1 [root@localhost ~]# vim -bash: vim: 未找到命令 安装vim yum -y install vim* # 查看是否安装成功 [root@hadoop01 hadoop]# rpm -qa |grep vim vim-X11-7.4.629-8.el7_9.x
使用sqoop一直卡在：mapreduce.Job: Running job: job_1703173956074_0001
修改hadoop配置 vi /usr/local/software/hadoop-2.9.2/etc/hadoop/yarn-site.xml # 添加如下 <configuration> <property> <name>yarn.nodemanager.res
pythonJavaScriptjavaHTMLPHPreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-boot