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 选项。