Создать/записать в очередь

Описание

Блок предназначен для создания или записи новых элементов в очередь.

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

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

1. ID-очереди - уникальный идентификатор очереди;

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

   Пример: list_of_companies

   Важно

   Идентификатор должен быть указан на латинице и не должен содержать пробелов.

2. Путь к файлу с данными - путь к файлу с данными на удаленной машине (csv-файл);

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

   Пример: /home/uadmin/list_of_companies.csv

3. Путь к оркестратору (Хост) - ip-адрес оркестратора;

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

   Пример: 10.100.115.121

4. Имя пользователя оркестратора

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

   Пример: admin

5. Пароль пользователя оркестратора

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

   Пример: password

6. Использовать подключение - ID подключения к удаленной машине (настройка доступна в разделе Connections оркестратора Airflow);
   Создание нового подключения Создание нового подключения в оркестраторе Airflow. Подробнее...

---

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

В данном примере создается очередь с указанными параметрами:

---

Результат

Создание очереди данных и последующий запуск роботов обрабатывающих очередь:

---