架构：

ACCOUNT_USAGE

SNOWPIPE_STREAMING_CLIENT_HISTORY 视图

This Account Usage view can be used to query the amount of time spent loading data into Snowflake tables using Snowpipe Streaming within the last 365 days (1 year). The view displays the amount of data loaded and timestamp of the Snowpipe Streaming client calls for your entire Snowflake account.

列

列名称

数据类型

描述

CLIENT_NAME

VARCHAR

Snowpipe Streaming 引入客户端的名称。

SNOWFLAKE_PROVIDED_ID

VARCHAR

用于数据加载的 Snowpipe Streaming 引入客户端的内部/系统生成的标识符。

EVENT_TIMESTAMP

TIMESTAMP_LTZ

发生数据加载的时间范围的开始时间（本地时区）。

EVENT_TYPE

VARCHAR

事件的类型。

BLOB_SIZE_BYTES

NUMBER

Blob 大小，以字节为单位。

使用说明

  • 视图的延迟时间最长可达 120 分钟（2 小时）。

示例

查询过去 365 天内使用 Snowpipe Streaming 将数据加载到 Snowflake 表所花费的时间。

SELECT * FROM SNOWFLAKE.ACCOUNT_USAGE.SNOWPIPE_STREAMING_CLIENT_HISTORY;
Copy

查询将返回以下结果。

+----------------+----------------------------+------------------------------+--------------+----------------+
|    CLIENT_NAME |    SNOWFLAKE_PROVIDED_ID   |              EVENT_TIMESTAMP |   EVENT_TYPE | BLOB_SIZE_BYTES|
|----------------+--------------------------- +------------------------------+--------------|----------------|
|      MY_CLIENT |FE0B1xJrBAAL3bAAUz1M9876nMCd| 2023-02-04 02:07:34.000 +0000| BLOB_PERSIST |           1,648|
|      MY_CLIENT |D1CIBBPGGFyprBanMvAA1234V3ss| 2023-02-04 02:15:54.000 +0000| BLOB_PERSIST |           3,120|
+----------------+----------------------------+------------------------------+--------------+----------------+
Copy

查询过去 365 天内每个客户端使用 Snowpipe Streaming 将数据加载到 Snowflake 表每小时使用的 Credit。

SELECT COUNT(DISTINCT event_timestamp) AS client_seconds, date_trunc('hour',event_timestamp) AS event_hour, client_seconds*0.000002777777778 as credits, client_name, snowflake_provided_id
FROM SNOWFLAKE.ACCOUNT_USAGE.SNOWPIPE_STREAMING_CLIENT_HISTORY
GROUP BY event_hour, client_name, snowflake_provided_id;
Copy

请注意，每秒可能会发生多个事件。Credit 仅按实际花费的时间使用，而不是按事件数量使用。

语言: 中文