VALIDATE_PIPE_LOAD¶

이 테이블 함수는 지정된 시간 범위 내에서 Snowpipe 가 처리하는 데이터 파일의 유효성을 검사하는 데 사용할 수 있습니다. 이 함수는 Snowflake 테이블에 데이터 로딩을 시도하는 동안 발생한 오류에 대한 세부 정보를 반환합니다.

참고

이 함수는 지난 14일 이내의 파이프 활동을 반환합니다.

구문¶

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

Copy

PIPE_NAME => string: 파이프를 지정하는 문자열입니다. 이 함수는 지정된 파이프에 대한 결과만 반환합니다.
START_TIME => constant_expr: 오류 이벤트 검색을 위한 시간 범위의 시작을 표시하는, 지난 14일 이내의 타임스탬프(TIMESTAMP_LTZ 형식)입니다.

선택 사항:

END_TIME => constant_expr: 오류 이벤트 검색을 위한 시간 범위의 끝을 표시하는, 지난 14일 이내의 타임스탬프(TIMESTAMP_LTZ 형식)입니다.

파이프 소유자(즉, 파이프에 대한 OWNERSHIP 권한이 있는 역할) 또는 다음과 같은 최소 권한이 있는 역할에 대한 결과만 반환합니다.

권한	오브젝트	참고
MONITOR	파이프	또는, 전역 MONITOR EXECUTION 권한이 지원됩니다.
USAGE	파이프 정의에서의 스테이지	외부 스테이지만
READ	파이프 정의에서의 스테이지	내부 스테이지만
SELECT	파이프 정의에서의 테이블
INSERT	파이프 정의에서의 테이블

스키마 오브젝트에 대한 SQL 작업에는 오브젝트를 포함하는 데이터베이스와 스키마에 대한 USAGE 권한도 필요합니다.

Information Schema 테이블 함수를 호출할 때 세션에는 사용 중인 INFORMATION_SCHEMA 스키마가 있거나 또는 함수 이름이 정규화되어야 합니다. 자세한 내용은 Snowflake Information Schema 섹션을 참조하십시오.
지정된 시간 범위 내에서 Snowpipe가 데이터 파일을 처리하는 동안 오류가 발생하지 않은 경우, 함수는 결과를 반환하지 않습니다.
로딩 중 데이터를 추가로 변환(즉, COPY 변환)하기 위한 쿼리가 파이프 설명의 COPY 문에 포함된 경우, 함수는 현재 사용자 오류를 반환합니다.
지정된 날짜 범위가 지난 15일을 벗어나면 오류가 반환됩니다.

이 함수는 다음 열을 반환합니다.

지난 1시간 이내 mypipe 파이프의 모든 로딩의 유효성을 검사합니다.

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

Copy