架构:

ACCOUNT_USAGE

SNOWPIPE_STREAMING_CHANNEL_HISTORY 视图

通道历史视图提供管道错误的历史记录,使用户能够监控性能趋势。此视图会显示关键指标,例如处理的数据量、错误率和延迟。

您可以使用此 Account Usage 视图,来查询特定管道或通道的错误历史记录。

列名称

数据类型

描述

ACCOUNT_ID

INT

Snowflake 账户的 ID。

CREATED_ON

TIMESTAMP_LTZ

创建行集合通道历史记录的日期和时间。

CHANNEL_ID

INT

由系统生成的 Snowpipe Streaming 通道的内部 ID。

PIPE_ID

INT

与此 Snowpipe Streaming 通道关联的 Snowpipe 对象的内部 ID。

END_OFFSET

STRING

已处理并包含在此特定通道历史记录中的最后一个偏移令牌。

TABLE_ID

INT

此 Snowpipe Streaming 通道的目标表的内部 ID。

TABLE_NAME

STRING

此 Snowpipe Streaming 通道的目标表的名称。

TABLE_SCHEMA_ID

INT

包含目标表的架构的内部 ID。

TABLE_SCHEMA_NAME

STRING

包含目标表的架构名称。

TABLE_DATABASE_ID

INT

包含目标表的数据库的内部 ID。

TABLE_DATABASE_NAME

STRING

包含目标表的数据库名称。

PIPE_NAME

STRING

与此 Snowpipe Streaming 通道关联的 Snowpipe 对象的用户定义名称。

PIPE_SCHEMA_ID

INT

包含此 Snowpipe 对象的架构的内部 ID。

PIPE_SCHEMA_NAME

STRING

包含此 Snowpipe 对象的架构的名称。

PIPE_DATABASE_ID

INT

包含此 Snowpipe 对象的数据库的内部 ID。

PIPE_DATABASE_NAME

STRING

包含此 Snowpipe 对象的数据库的名称。

LAST_ERROR_OFFSET_UPPER_BOUND

STRING

在此历史时间段内,遇到错误的最后一个行集合的偏移令牌范围的上限。

LAST_ERROR_MESSAGE

STRING

显示 NULL。

SNOWFLAKE_PROCESSING_LATENCY_MS

NUMBER

在此历史时间段内,Snowflake 服务在处理该通道的行集合时观察到的平均延迟,以毫秒为单位。

ROWS_INSERTED

NUMBER

在此历史时间段内,通过此通道成功插入的总行数。

ROWS_PARSED

NUMBER

在此历史时间段内,该通道解析(处理)的总行数。

ROW_ERROR_COUNT

NUMBER

在此历史时间段内,遇到错误且并未通过此通道插入的行总数。

使用说明

  • Snowpipe Streaming 高性能架构仅支持 ON_ERROR=CONTINUE。不支持其他 ON_ERROR 选项。

语言: 中文