架构：

ACCOUNT_USAGE

SNOWPIPE_STREAMING_CLIENT_HISTORY 视图

此 Account Usage 视图可用于查询过去 365 天（1 年）内使用 Snowpipe Streaming 将数据加载到 Snowflake 表中所花费的时间。此视图显示整个 Snowflake 账户的 Snowpipe Streaming 客户端调用的加载数据量和时间戳。

列

列名称

数据类型

描述

CLIENT_NAME

TEXT

Snowpipe Streaming 引入客户端的名称。

SNOWFLAKE_PROVIDED_ID

TEXT

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

EVENT_TIMESTAMP

TIMESTAMP_LTZ

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

EVENT_TYPE

TEXT

事件的类型。

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 仅按实际花费的时间使用，而不是按事件数量使用。

语言: 中文