Перейти к основному содержимому
Версия: 1.5.x

SHOW PIPES

SHOW PIPES выводит список пайпов, хранящихся в указанной базе данных или в текущей используемой базе данных. Эта команда поддерживается начиная с версии 1.5.0.

Синтаксис​

SHOW PIPES [FROM <db_name>]
[
   WHERE [ NAME { = "<pipe_name>" | LIKE "pipe_matcher" } ]
         [ [AND] STATE = { "SUSPENDED" | "RUNNING" | "ERROR" } ]
]
[ ORDER BY <field_name> [ ASC | DESC ] ]
[ LIMIT { [offset, ] limit | limit OFFSET offset } ]

Параметры​

FROM <db_name>​

Имя базы данных, для которой вы хотите запросить пайпы. Если вы не указываете этот параметр, система возвращает пайпы для текущей используемой базы данных.

WHERE​

Критерии, на основе которых выполняется запрос пайпов.

ORDER BY <field_name>​

Поле, по которому вы хотите отсортировать возвращаемые записи.

LIMIT​

Максимальное количество записей, которое система должна вернуть.

Результат выполнения​

Вывод команды состоит из следующих полей.

ПолеОписание
DATABASE_NAMEИмя базы данных, в которой хранится пайп.
PIPE_IDУникальный ID пайпа.
PIPE_NAMEИмя пайпа.
TABLE_NAMEИмя целевой таблицы Selena.
STATEСтатус пайпа. Допустимые значения: RUNNING, FINISHED, SUSPENDED и ERROR.
LOAD_STATUSОбщий статус файлов данных, которые должны быть загружены через пайп, включая следующие подполя:
  • loadedFiles: количество загруженных файлов данных.
  • loadedBytes: объем загруженных данных в байтах.
  • LastLoadedTime: дата и время загрузки последнего файла данных. Формат: yyyy-MM-dd HH:mm:ss. Пример: 2023-07-24 14:58:58.
LAST_ERRORПодробности о последней ошибке, возникшей во время выполнения пайпа. Значение по умолчанию: NULL.
CREATED_TIMEДата и время создания пайпа. Формат: yyyy-MM-dd HH:mm:ss. Пример: 2023-07-24 14:58:58.

Примеры​

Запрос всех пайпов​

Переключитесь на базу данных с именем mydatabase и покажите все пайпы в ней:

USE mydatabase;
SHOW PIPES \G

Запрос указанного пайпа​

Переключитесь на базу данных с именем mydatabase и покажите пайп с именем user_behavior_replica в ней:

USE mydatabase;
SHOW PIPES WHERE NAME = 'user_behavior_replica' \G

Ссылки​