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

SHOW PIPES

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

Синтаксис​

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>​

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

WHERE​

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

ORDER BY <field_name>​

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

LIMIT​

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

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

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

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

Примеры​

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

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

USE mydatabase;
SHOW PIPES \G

Запрос конкретного pipe​

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

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

Ссылки​