Перейти к содержимому

Робот потребитель (Dag)

image_1

Описание

Блок предназначен для создания процесса потребителя данных из очереди данных и последующей передачи его в оркестратор. Процесс автоматически запускается при обновлении данных в очереди.

Описание параметров

Блок имеет несколько основных параметров:

  1. Наименование - уникальный идентификатор процесса, отображаемый в веб-интерфейсе оркестратора.

    Тип данных: строка

    Пример: puzzle_robot

  2. Описание - краткое описание процесса для отображения в интерфейсе оркестратора;

    Тип данных: строка

    Пример: Обрабатывает очередь на 181 ВМ

  3. Дата отсчета интервала - дата, с которой нужно начинать планирование запуска процесса;

    Тип данных: строка

    Пример: 01.01.2025

    Если выбрать 1 января 2025 года, то первое выполнение произойдёт в 23:59:59 того же дня.
  4. ID-очереди для обработки - уникальный идентификатор очереди, данные из которой будут обрабатываться процессом;

    Тип данных: строка

    Пример: list_of_companies

  5. Одновременный запуск процессов - максимальное количество процессов, выполняемых одновременно;

    Тип данных: число

    Пример: 1

  6. Теги - набор меток для сортировки процессов в веб-интерфейсе. Можно указать несколько тегов для одного процесса;

    Тип данных: список строк

  7. Аргументы по умолчанию:
    • owner - владелец процесса;

      Тип данных: строка

      Пример: Puzzle RPA

    • depends_on_past - стоит ли инициировать запуск следующего процесса, если предыдущий процесс в цепочке операций завершился с ошибкой;

      Тип данных: логический (boolean)

      Пример: Истина

    • email - список адресов электронной почты, для уведомлений о статусе выполнения;

      Тип данных: список строк

    • email_on_failure - нужно ли отправлять уведомления на адрес электронной почты в случае неудачного выполнения;

      Тип данных: логический (boolean)

      Пример: Истина

    • pool - параметр для управления очередями между различными процессами оркестратора.

      Тип данных: строка

      Пример: default_pool

  8. Использовать подключение - ID подключения к удаленной машине (настройка доступна в разделе Connections оркестратора Airflow);
  9. Директория используемой студии - путь к директории установки студии Puzzle RPA на удаленной виртуальной машине.;

    Тип данных: строка

    Пример: C:\Program Files\PuzzleRPA\2.0.0

  10. Тип ОС - тип операционной системы, на которой будет запускаться робот;

    Тип данных: строка

    Пример: Windows

  11. Путь к роботу на сервере - путь до робота на сервере оркестратора, используемый для отправки робота на удалённую виртуальную машину;

    Тип данных: строка

    Пример: /opt/airflow/scripts/robot

  12. Название главного процесса - указывается, если проект робота состоит из нескольких процессов;

    Тип данных: строка | логическое ничто

    Пример: None

  13. Обработать элементов очереди (количество) - количество элементов очереди, которые робот забирает на обработку за один запуск;

    Тип данных: число

    Пример: 3

  14. Таймаут (в секундах) выполнения робота - максимальное время работы процесса на удаленной виртуальной машине.

    Тип данных: число

    Пример: 3


Пример использования

В данном примере создаётся процесс-потребитель для оркестратора с заданными параметрам:

image_2

Результат

После загрузки созданного процесса в оркестратор, в его интерфейсе появится информация о созданном процессе.

image_3