DESCRIBE PIPE_云原生多模数据库 Lindorm(Lindorm)-阿里云帮助中心

DESCRIBE PIPE语句用于显示Lindorm消息引擎中已创建的Mirror Link链路的详细信息，方便用户实施管理。

引擎与版本

DESCRIBE PIPE语法仅适用于消息引擎。
消息引擎3.8.0及以上版本支持DESCRIBE PIPE语法。

重要

要求Lindorm SQL为2.7.0 以上版本。如何查看Lindorm SQL的版本，请参见SQL版本说明。

语法

describe_pipe_statement   ::=  DESCRIBE PIPE pipe_identifier

使用说明

Mirror Link链路名（pipe_identifier）

需要指定一个已经存在的Mirror Link链路名。

返回结果集说明

语句执行结果会通过表的形式进行呈现，表的字段如下：

字段	说明
PIPE_NAME	Mirror Link链路名。
SINK_TABLE	数据导入链路的目标流表名。
SOURCE_TOPIC	数据导入链路的源Kafka主题名。
SOURCE_SERVERS	数据导入链路的源Kafka集群地址。
START_TIMESTAMP	数据导入开始时间戳。
PIPE_PROPERTIES	链路属性明细。
PIPE_STATUS	链路的任务运行状态。包括： INITIALIZING：初始化中。 CREATED：已创建。 RUNNING：运行中。 FAILING：失败，错误可恢复。 FAILED：失败，错误不可恢复。 CANCELLING：取消中。 CANCELED：已取消。 FINISHED：已完成。 RESTARTING：重启中。
PIPE_DURATION	链路的任务已运行的时间。单位为毫秒（ms）。
RECORDS_LAG_MAX	被同步主题的所有分区的最大记录滞后量。
CURRENT_EMIT_EVENT_TIME_LAG	当前处理的事件延迟时间。单位为毫秒（ms）。

示例

展示一个名为pip3的Mirror Link链路状态。

DESCRIBE PIPE pip3;

返回结果：

+-----------+------------+--------------+----------------+-----------------+-----------------------------------------------------------------------------------+-------------+---------------+-----------------+-----------------------------+
| PIPE_NAME | SINK_TABLE | SOURCE_TOPIC | SOURCE_SERVERS | START_TIMESTAMP | PIPE_PROPERTIES                                                                   | PIPE_STATUS | PIPE_DURATION | RECORDS_LAG_MAX | CURRENT_EMIT_EVENT_TIME_LAG |
+-----------+------------+--------------+----------------+-----------------+-----------------------------------------------------------------------------------+-------------+---------------+-----------------+-----------------------------+
| pip3      | goal2      | source2      | stream-1:30080 | 1716528614865   | {"scan.startup.mode":"timestamp","scan.startup.timestamp-millis":"1708910643000"} | RUNNING     | 25948         | 0               | 38903                       |
+-----------+------------+--------------+----------------+-----------------+-----------------------------------------------------------------------------------+-------------+---------------+-----------------+-----------------------------+