架构：: ORGANIZATION_USAGE

PIPES 视图¶

重要

此视图仅在组织账户中可用。有关更多信息，请参阅组织账户中的高级视图。

此 Organization Usage 视图为账户中定义的每个管道显示一行。

列¶

组织级列

列名称	数据类型	描述
ORGANIZATION_NAME	VARCHAR	组织的名称。
ACCOUNT_LOCATOR	VARCHAR	系统为账户生成的标识符。
ACCOUNT_NAME	VARCHAR	用户定义的账户标识符。

其他列

列名称	数据类型	描述
PIPE_ID	NUMBER	Internal or system-generated identifier for the pipe.
PIPE_NAME	VARCHAR	The name of the pipe object. 对于手动创建的管道，这是在 CREATE PIPE 语句中定义的名称。对于 Snowpipe Streaming 高性能默认管道，该名称派生自目标表名称；例如 `MY_TABLE-STREAMING`。
PIPE_SCHEMA_ID	NUMBER	Internal or system-generated identifier for the schema that the pipe belongs to. 对于默认管道，这对应于目标表的架构 ID。
PIPE_SCHEMA	VARCHAR	管道所属的架构。对于默认管道，这对应于目标表的架构。
PIPE_CATALOG_ID	NUMBER	Internal or system-generated identifier for the database that the pipe belongs to. 对于默认管道，这对应于目标表的数据库 ID。
PIPE_CATALOG	VARCHAR	Name of the database that the pipe belongs to. 对于默认管道，这对应于目标表的数据库。
IS_AUTOINGEST_ENABLED	VARCHAR	是否为管道启用了 AUTO-INGEST。表示将来的功能。
NOTIFICATION_CHANNEL_NAME	VARCHAR	DEFINITION 列中命名的暂存区的 Amazon SQS 队列的 Amazon Resource Name。表示将来的功能。
PIPE_OWNER	VARCHAR	拥有管道的角色的名称。对于默认管道，返回 NULL。
DEFINITION	VARCHAR	COPY 语句用于将排队文件中的数据加载到 Snowflake 表中。
CREATED	TIMESTAMP_LTZ	管道的创建时间。
LAST_ALTERED	TIMESTAMP_LTZ	对象上次经 DML、DDL 或后台元数据操作修改的日期和时间。请参阅使用说明。
COMMENT	VARCHAR	此管道的注释。对于默认管道，返回以下消息：“Default pipe for Snowpipe Streaming High Performance ingestion to a table.Created and managed by Snowflake.”
PATTERN	VARCHAR	管道定义中的 COPY INTO <table> 语句中的 PATTERN 复制选项值（如果指定了复制选项）。
DELETED	TIMESTAMP_LTZ	删除管道的日期和时间。
OWNER_ROLE_TYPE	VARCHAR	拥有对象的角色类型；例如 ROLE。如果 Snowflake Native App 拥有该对象，则值为 APPLICATION。如果您删除该对象，则 Snowflake 会返回 NULL，原因是删除的对象不具有所有者角色。对于默认管道，返回 NULL。

使用说明¶

视图的延迟时间最长可达 24 小时。

该视图仅显示会话的当前角色已被授予访问权限的对象。
该视图无法识别 MANAGE GRANTS 权限，因此与拥有 MANAGE GRANTS 权限的用户执行的 SHOW 命令相比，显示的信息可能更少。
对对象执行以下操作时，将更新 LAST_ALTERED 列：
- DDL 操作。
- DML 操作（仅适用于表）。即使 DML 语句不影响任何行，也会更新此列。
- 由 Snowflake 对元数据执行的后台维护操作。

示例¶

以下示例将此视图与 PIPE_ID 列上的 PIPE_USAGE_HISTORY 视图联接，以跟踪与每个唯一 PIPE 对象关联的 credit 使用量：

select a.PIPE_CATALOG as PIPE_CATALOG,
       a.PIPE_SCHEMA as PIPE_SCHEMA,
       a.PIPE_NAME as PIPE_NAME,
       b.CREDITS_USED as CREDITS_USED
from SNOWFLAKE.ORGANIZATION_USAGE.PIPES a join SNOWFLAKE.ORGANIZATION_USAGE.PIPE_USAGE_HISTORY b
on a.pipe_id = b.pipe_id
where b.START_TIME > date_trunc(month, current_date);

Copy