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

Функция таблицы urlCluster

Позволяет обрабатывать файлы по URL в параллельном режиме с многих узлов в указанном кластере. На инициаторе она создает соединение со всеми узлами в кластере, раскрывает знак звездочки в пути к файлу URL и динамически распределяет каждый файл. На рабочем узле она запрашивает у инициатора следующую задачу для обработки и выполняет её. Это повторяется до тех пор, пока все задачи не будут завершены.

Синтаксис

Аргументы

  • cluster_name — Название кластера, который используется для построения набора адресов и параметров соединения с удаленными и локальными серверами.
  • URL — HTTP или HTTPS адрес сервера, который может принимать GET запросы. Тип: Строка.
  • format — Формат данных. Тип: Строка.
  • structure — Структура таблицы в формате 'UserID UInt64, Name String'. Определяет имена и типы колонок. Тип: Строка.

Возвращаемое значение

Таблица с указанным форматом и структурой и данными из заданного URL.

Примеры

Получение первых 3 строк таблицы, которая содержит колонки типов String и UInt32 с HTTP-сервера, который отвечает в формате CSV.

  1. Создайте базовый HTTP сервер, используя стандартные инструменты Python 3, и запустите его:

Глобусы в URL​

Шаблоны в фигурных скобках { } используются для генерации набора шардов или для указания запасных адресов. Поддерживаемые типы шаблонов и примеры смотрите в описании функции remote.

Символ | внутри шаблонов используется для указания запасных адресов. Они перебираются в том же порядке, в каком перечислены в шаблоне. Количество сгенерированных адресов ограничено настройкой glob_expansion_max_elements.

Смотрите также