Робот потребитель (Dag)
Описание
Блок предназначен для создания процесса потребителя данных из очереди данных и последующей передачи его в оркестратор. Процесс автоматически запускается при обновлении данных в очереди.
Описание параметров
Блок имеет несколько основных параметров:
- Наименование - уникальный идентификатор процесса, отображаемый в веб-интерфейсе оркестратора.
Тип данных:
строкаПример:
puzzle_robot - Описание - краткое описание процесса для отображения в интерфейсе оркестратора;
Тип данных:
строкаПример:
Обрабатывает очередь на 181 ВМ - Дата отсчета интервала - дата, с которой нужно начинать планирование запуска процесса;
Если выбрать 1 января 2025 года, то первое выполнение произойдёт в 23:59:59 того же дня.
Тип данных:
строкаПример:
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
Пример использования
В данном примере создаётся процесс-потребитель для оркестратора с заданными параметрам:
Результат
После загрузки созданного процесса в оркестратор, в его интерфейсе появится информация о созданном процессе.