- 스키마:
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;
쿼리에서 반환되는 결과는 다음과 같습니다.
+----------------+----------------------------+------------------------------+--------------+----------------+ | 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| +----------------+----------------------------+------------------------------+--------------+----------------+
지난 365일 이내에 Snowpipe Streaming을 사용하여 Snowflake 테이블에 데이터를 로드하는 각 클라이언트가 쓴 시간당 크레딧을 쿼리합니다.
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;
초당 여러 개의 이벤트가 있을 수 있습니다. 크레딧은 이벤트 수가 아닌 실제 소요 시간으로만 소비됩니다.