VALIDATE_PIPE_LOAD

VALIDATE_PIPE_LOAD (파이프 로드 검증)

이 테이블 함수는 지정된 시간 범위 내에 Snowpipe가 처리한 데이터 파일을 검증하는 데 사용할 수 있어요. 이 함수는 Snowflake 테이블로의 데이터 로드 시도 중 발생한 오류에 대한 세부 정보를 반환해요.

출처: Snowflake SQL Reference - VALIDATE_PIPE_LOAD

본문

참고: 이 함수는 최근 14일 이내의 파이프 활동을 반환해요.

구문

VALIDATE_PIPE_LOAD(
 PIPE_NAME => '<string>'
 , START_TIME => <constant_expr>
 [, END_TIME => <constant_expr> ] )

인자

PIPE_NAME => string

파이프를 지정하는 문자열이에요. 이 함수는 지정된 파이프에 대해서만 결과를 반환해요.

START_TIME => constant_expr

최근 14일 이내의 타임스탬프(TIMESTAMP_LTZ 형식)로, 오류 이벤트를 검색할 시간 범위의 시작을 나타내요.

선택:

END_TIME => constant_expr

최근 14일 이내의 타임스탬프(TIMESTAMP_LTZ 형식)로, 오류 이벤트를 검색할 시간 범위의 끝을 나타내요.

사용 시 참고 사항

• 파이프 소유자(즉, 파이프에 대한 OWNERSHIP 권한을 가진 역할) 또는 다음 최소 권한을 가진 역할에 대해서만 결과를 반환해요.

• Information Schema 테이블 함수를 호출할 때, 세션에 사용 중인 INFORMATION_SCHEMA 스키마가 있거나 함수 이름이 완전히 한정되어야 해요. 자세한 내용은 Snowflake Information Schema를 참고하세요.

• 지정된 시간 범위 내에 데이터 파일을 처리하는 동안 Snowpipe에 오류가 없었다면, 함수는 결과를 반환하지 않아요.

• 파이프 설명의 COPY 문에 로드 중 데이터를 추가로 변환하는 쿼리(즉 COPY 변환)가 포함되어 있으면, 이 함수는 현재 사용자 오류를 반환해요.

• 지정된 날짜 범위가 최근 15일을 벗어나면 오류가 반환돼요.

출력

이 함수는 다음 열을 반환해요.

예시

이전 한 시간 내에 mypipe 파이프에 대한 로드를 검증해요.

select * from table(validate_pipe_load(
 pipe_name=>'MY_DB.PUBLIC.MYPIPE',
 start_time=>dateadd(hour, -1, current_timestamp())));

더 알아보기

• Information Schema
• Table functions