跳到主要内容
版本: 最新版本-3.5

SHOW PIPES

SHOW PIPES 列出存储在指定数据库或当前正在使用的数据库中的管道。此命令从 v3.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>​

您要查询管道的数据库的名称。如果未指定此参数，系统将返回当前正在使用的数据库的管道。

WHERE​

查询管道所依据的条件。

ORDER BY <field_name>​

您要对返回的记录进行排序的字段。

LIMIT​

您希望系统返回的最大记录数。

返回结果​

命令输出包含以下字段。

字段描述
DATABASE_NAMEPipe 所在的数据库名称。
PIPE_IDPipe 的唯一 ID。
PIPE_NAMEPipe 的名称。
TABLE_NAME目标 StarRocks 表的名称。
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

参考​