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

Описание
Блок предназначен для создания процесса потребителя данных из очереди данных и последующей передачи его в оркестратор. Процесс автоматически запускается при обновлении данных в очереди.
Описание параметров
Блок имеет несколько основных параметров:
- Наименование - уникальный идентификатор процесса, отображаемый в веб-интерфейсе оркестратора.
Тип данных:
строка
Пример:
puzzle_robot
- Описание - краткое описание процесса для отображения в интерфейсе оркестратора;
Тип данных:
строка
Пример:
Обрабатывает очередь на 181 ВМ
- Дата отсчета интервала - дата, с которой нужно начинать планирование запуска процесса;
Тип данных:
строка
Пример:
01.01.2025
- ID-очереди для обработки - уникальный идентификатор очереди, данные из которой будут обрабатываться процессом;
Тип данных:
строка
Пример:
list_of_companies
- Одновременный запуск процессов - максимальное количество процессов, выполняемых одновременно;
Тип данных:
число
Пример:
1
- Теги - набор меток для сортировки процессов в веб-интерфейсе. Можно указать несколько тегов для одного процесса;
Тип данных:
список строк
- Аргументы по умолчанию:
- owner - владелец процесса;
Тип данных:
строка
Пример:
Puzzle RPA
- depends_on_past - стоит ли инициировать запуск следующего процесса, если предыдущий процесс в цепочке операций завершился с ошибкой;
Тип данных:
логический (boolean)
Пример:
Истина
- email - список адресов электронной почты, для уведомлений о статусе выполнения;
Тип данных:
список строк
- email_on_failure - нужно ли отправлять уведомления на адрес электронной почты в случае неудачного выполнения;
Тип данных:
логический (boolean)
Пример:
Истина
- pool - параметр для управления очередями между различными процессами оркестратора.
Тип данных:
строка
Пример:
default_pool
- owner - владелец процесса;
- Использовать подключение - ID подключения к удаленной машине (настройка доступна в разделе Connections оркестратора Airflow);
Создание нового подключения Создание нового подключения в оркестраторе Airflow. Подробнее...
- Директория используемой студии - путь к директории установки студии Puzzle RPA на удаленной виртуальной машине.;
Тип данных:
строка
Пример:
C:\Program Files\PuzzleRPA\2.0.0
- Тип ОС - тип операционной системы, на которой будет запускаться робот;
Тип данных:
строка
Пример:
Windows
- Путь к роботу на сервере - путь до робота на сервере оркестратора, используемый для отправки робота на удалённую виртуальную машину;
Тип данных:
строка
Пример:
/opt/airflow/scripts/robot
- Название главного процесса - указывается, если проект робота состоит из нескольких процессов;
Тип данных:
строка | логическое ничто
Пример:
None
Тип данных:
строка
Пример:
robot.py
- Обработать элементов очереди (количество) - количество элементов очереди, которые робот забирает на обработку за один запуск;
Тип данных:
число
Пример:
3
- Таймаут (в секундах) выполнения робота - максимальное время работы процесса на удаленной виртуальной машине.
Тип данных:
число
Пример:
3
Пример использования
В данном примере создаётся процесс-потребитель для оркестратора с заданными параметрам:

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