Асинхронные действия и опрос

Предотвращение тайм-аутов соединения: poll > 0

Если вы хотите увеличить ограничение по времени для определённой задачи в плейбуке, используйте async, задав для poll положительное значение. Ansible по-прежнему будет блокировать следующую задачу в плейбуке, ожидая завершения асинхронной задачи, её сбоя или истечения времени ожидания. Однако время ожидания задачи истечёт только в том случае, если она превысит ограничение, заданное параметром async.

Чтобы предотвратить тайм-аут задачи, укажите максимальное время её выполнения и частоту проверки состояния:

---

- hosts: all
  remote_user: root

  tasks:

  - name: Simulate long running op (15 sec), wait for up to 45 sec, poll every 5 sec
    ansible.builtin.command: /bin/sleep 15
    async: 45
    poll: 5

Параллельное выполнение задач: poll = 0

Если вы хотите параллельно выполнять несколько задач в плейбуке, используйте async, задав для poll значение 0. При задании poll: 0 Ansible запускает задачу и сразу переходит к следующей, не ожидая результата. Каждая асинхронная задача выполняется до завершения, сбоя или истечения времени ожидания (если её длительность превышает значение async). Выполнение плейбука заканчивается без повторной проверки асинхронных задач.

Чтобы выполнить задачу плейбука асинхронно:

---

- hosts: all
  remote_user: root

  tasks:

  - name: Simulate long running op, allow to run for 45 sec, fire and forget
    ansible.builtin.command: /bin/sleep 15
    async: 45
    poll: 0

Если для асинхронной задачи требуется точка синхронизации, зарегистрируйте её, чтобы получить идентификатор задания, а затем используйте модуль async_status для проверки её состояния в последующей задаче. Например:

- name: Run an async task
  ansible.builtin.yum:
    name: docker-io
    state: present
  async: 1000
  poll: 0
  register: yum_sleeper

- name: Check on an async task
  async_status:
    jid: "{{ yum_sleeper.ansible_job_id }}"
  register: job_result
  until: job_result is finished
  retries: 100
  delay: 10

Чтобы выполнять несколько асинхронных задач, ограничивая число одновременно выполняемых задач:

#####################
# main.yml
#####################
- name: Run items asynchronously in batch of two items
  vars:
    sleep_durations:
      - 1
      - 2
      - 3
      - 4
      - 5
    durations: "{{ item }}"
  include_tasks: execute_batch.yml
  loop: "{{ sleep_durations | batch(2) | list }}"

#####################
# execute_batch.yml
#####################
- name: Async sleeping for batched_items
  ansible.builtin.command: sleep {{ async_item }}
  async: 45
  poll: 0
  loop: "{{ durations }}"
  loop_control:
    loop_var: "async_item"
  register: async_results

- name: Check sync status
  async_status:
    jid: "{{ async_result_item.ansible_job_id }}"
  loop: "{{ async_results.results }}"
  loop_control:
    loop_var: "async_result_item"
  register: async_poll_results
  until: async_poll_results is finished
  retries: 30