如何在Snowflake DB中查询Pipe的依赖对象？

算力阿峰

2026-7-22

获取Snowflake Pipe依赖对象的方法

由于Snowflake的OBJECT_DEPENDENCIES视图不包含Pipe的依赖关系，你可以通过以下几种方式获取Pipe所依赖的对象：

1. 直接查看Pipe定义（DESCRIBE命令）

执行DESCRIBE PIPE <你的Pipe全称>命令，结果中的DEFINITION字段会显示完整的Pipe创建语句，从中可以直接提取出依赖的目标表、源阶段（Stage）和文件格式（File Format）。

示例命令：

DESCRIBE PIPE MY_DB.MY_SCHEMA.MY_PIPE;

2. 查询INFORMATION_SCHEMA视图

通过INFORMATION_SCHEMA.PIPES视图获取所有Pipe的定义，再通过正则表达式解析出依赖对象：

SELECT
  PIPE_NAME,
  -- 提取目标表
  REGEXP_SUBSTR(PIPE_DEFINITION, 'COPY INTO ([^ ]+)', 1, 1, 'e') AS TARGET_TABLE,
  -- 提取源阶段
  REGEXP_SUBSTR(PIPE_DEFINITION, 'FROM @([^ ]+)', 1, 1, 'e') AS SOURCE_STAGE,
  -- 提取文件格式
  REGEXP_SUBSTR(PIPE_DEFINITION, 'FILE_FORMAT = ([^ ]+)', 1, 1, 'e') AS FILE_FORMAT
FROM INFORMATION_SCHEMA.PIPES
WHERE PIPE_CATALOG = '你的数据库名' AND PIPE_SCHEMA = '你的Schema名';

3. 账户级范围查询（ACCOUNT_USAGE）

如果需要查看整个账户内所有Pipe的依赖，可以使用ACCOUNT_USAGE.PIPES视图，同样通过正则解析定义字段：

SELECT
  DATABASE_NAME,
  SCHEMA_NAME,
  PIPE_NAME,
  REGEXP_SUBSTR(PIPE_DEFINITION, 'COPY INTO ([^ ]+)', 1, 1, 'e') AS TARGET_TABLE,
  REGEXP_SUBSTR(PIPE_DEFINITION, 'FROM @([^ ]+)', 1, 1, 'e') AS SOURCE_STAGE,
  REGEXP_SUBSTR(PIPE_DEFINITION, 'FILE_FORMAT = ([^ ]+)', 1, 1, 'e') AS FILE_FORMAT
FROM ACCOUNT_USAGE.PIPES;