架构:

ACCOUNT_USAGE

SNOWPIPE_STREAMING_CHANNEL_HISTORY 视图

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

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

备注

The SNOWPIPE_STREAMING_CHANNEL_HISTORY view only applies to Snowpipe Streaming with high-performance architecture.

列名称

数据类型

描述

ACCOUNT_ID

NUMBER

Snowflake 账户的 ID。

CREATED_ON

TIMESTAMP_LTZ

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

CHANNEL_ID

NUMBER

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

CHANNEL_NAME

VARCHAR

The user-defined name of the Snowpipe Streaming channel.

PIPE_ID

NUMBER

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

END_OFFSET

VARCHAR

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

TABLE_ID

NUMBER

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

TABLE_NAME

VARCHAR

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

TABLE_SCHEMA_ID

NUMBER

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

TABLE_SCHEMA_NAME

VARCHAR

包含目标表的架构名称。

TABLE_DATABASE_ID

NUMBER

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

TABLE_DATABASE_NAME

VARCHAR

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

PIPE_NAME

VARCHAR

The name of the Snowpipe object associated with the current Snowpipe Streaming channel history entry.

Named pipes: The value is the user-defined name of the Snowpipe object associated with the channel.

Default pipe: The value is automatically derived from the target table name; for example, MY_TABLE-STREAMING.

PIPE_SCHEMA_ID

NUMBER

The internal identifier for the schema associated with the Snowpipe Streaming channel.

Named pipes: The value is the internal ID of the schema that contains the user-defined Snowpipe object.

Default pipe: The value is the internal ID of the schema that contains the target table.

PIPE_SCHEMA_NAME

VARCHAR

The name of the schema associated with the Snowpipe Streaming channel.

Named pipes: The value is the user-defined name of the schema that contains the Snowpipe object.

Default pipe: The value is the name of the schema that contains the target table.

PIPE_DATABASE_ID

NUMBER

The internal identifier for the database associated with the Snowpipe Streaming channel.

Named pipes: The value is the internal ID of the database that contains the user-defined Snowpipe object.

Default pipe: The value is the internal ID of the database that contains the target table.

PIPE_DATABASE_NAME

VARCHAR

The name of the database associated with the Snowpipe Streaming channel.

Named pipes: The value is the user-defined name of the database that contains the Snowpipe object.

Default pipe: The value is the name of the database that contains the target table.

LAST_ERROR_OFFSET_UPPER_BOUND

VARCHAR

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

LAST_ERROR_MESSAGE

VARCHAR

The last error message encountered while writing data to the channel. This column displays a redacted error message when an error is encountered.

SNOWFLAKE_PROCESSING_LATENCY_MS

NUMBER

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

ROWS_INSERTED

NUMBER

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

ROWS_PARSED

NUMBER

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

ROW_ERROR_COUNT

NUMBER

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

使用说明

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