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

По умолчанию задачи в плейбуках блокируют выполнение, то есть соединения остаются открытыми до завершения задачи на каждом узле. Это не всегда желательно, или вы можете запускать операции, которые занимают больше времени, чем таймаут SSH.

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

Чтобы запустить задачу асинхронно, укажите максимальное время её выполнения и частоту опроса статуса. Значение опроса по умолчанию составляет 10 секунд, если вы не укажете другое значение для poll:

---

- hosts: all
  remote_user: root

  tasks:

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

В качестве альтернативы, если вам не нужно ждать завершения задачи, вы можете запустить её асинхронно, указав значение опроса 0:

---

- hosts: all
  remote_user: root

  tasks:

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

Если вы хотите выполнить задачу асинхронно и проверить её позже, вы можете выполнить задачу, подобную следующей:

---
# Requires ansible 1.8+
- name: 'YUM - async task'
  yum:
    name: docker-io
    state: installed
  async: 1000
  poll: 0
  register: yum_sleeper

- name: 'YUM - check on async task'
  async_status:
    jid: "{{ yum_sleeper.ansible_job_id }}"
  register: job_result
  until: job_result.finished
  retries: 30

Если вы хотите запустить несколько асинхронных задач, ограничив количество выполняемых одновременно, вы можете сделать это следующим образом:

#####################
# 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
  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.finished
  retries: 30