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

По умолчанию задачи в плейбуках блокируют выполнение, то есть соединения остаются открытыми до завершения задачи на каждом узле. Это может быть нежелательно, или же вы можете запускать операции, которые занимают больше времени, чем время ожидания 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