ARA-C01 문제 76
아래 단계에 따라 작업과 스트림을 만듭니다. 그래서,
system$stream_has_data('rawstream1') 조건이 false를 반환하면 작업은 어떻게 되나요?
-- 원시 JSON 데이터를 저장할 랜딩 테이블을 생성합니다.
-- Snowpipe는 이 테이블에 데이터를 로드할 수 있습니다. 원시 테이블 생성 또는 교체(var 변형)
-- 랜딩 테이블에 대한 삽입을 캡처하는 스트림을 생성합니다.
-- 작업은 이 스트림의 열 집합을 사용합니다. raw 테이블에서 rawstream1 스트림을 생성하거나 교체합니다.
-- 두 번째 스트림을 생성하여 랜딩 테이블에 대한 삽입을 캡처합니다.
-- 두 번째 작업은 이 스트림의 다른 열 집합을 사용합니다. raw 테이블에서 rawstream2 스트림을 생성하거나 교체합니다.
-- 원시 데이터에서 식별된 사무실 방문자의 이름을 저장하는 테이블을 생성합니다. 테이블 이름 생성 또는 교체(id int, first_name 문자열, last_name 문자열)
-- 원시 데이터에서 식별된 사무실 방문자의 방문 날짜를 저장하는 테이블을 생성합니다.
테이블 방문 생성 또는 교체(id int, dt date)
-- rawstream1 스트림의 새 이름 레코드를 이름 테이블에 삽입하는 작업을 만듭니다.
-- 스트림에 레코드가 포함된 경우 1분마다.
-- 'etl_wh' 웨어하우스를 귀하의 역할에 USAGE 권한이 있는 웨어하우스로 바꾸십시오. raw_to_names 작업 생성 또는 교체
창고 = etl_wh 일정 = '1분' 일 때
system$stream_has_data('rawstream1')
이름 n으로 병합
n.id = to_number(r1.id)에서 (rawstream1에서 var:id id, var:fname fname, var:lname lname 선택) r1 사용
일치하면 업데이트 세트 n.first_name = r1.fname, n.last_name = r1.lname
일치하지 않으면 (id, first_name, last_name) 값(r1.id, r1.fname, r1.lname)을 삽입합니다.
;
-- rawstream1 스트림의 방문 기록을 방문 테이블에 병합하는 또 다른 작업을 만듭니다.
-- 스트림에 레코드가 포함된 경우 1분마다.
-- 새 ID가 있는 기록이 방문 테이블에 삽입됩니다.
-- 방문 테이블에 존재하는 ID가 있는 레코드는 테이블의 DT 열을 업데이트합니다.
-- 'etl_wh' 웨어하우스를 귀하의 역할에 USAGE 권한이 있는 웨어하우스로 바꾸십시오. 작업 raw_to_visits 생성 또는 교체
창고 = etl_wh 일정 = '1분' 일 때
system$stream_has_data('rawstream2')
방문 v로 병합
(rawstream2에서 var:id id, var:visit_dt Visit_dt 선택) r2 on v.id = to_number(r2.id) 일치 시 v.dt = r2.visit_dt 설정 업데이트 사용
일치하지 않으면 (id, dt) 값(r2.id, r2.visit_dt)을 삽입합니다.
;
-- 두 작업을 모두 재개합니다.
작업 변경 raw_to_names 이력서;
작업 변경 raw_to_visits 이력서;
-- 랜딩 테이블에 레코드 집합을 삽입합니다. 원시에 삽입
값에서 parse_json(column1)을 선택하세요.
('{"id": "123","fname": "Jane","lname": "Smith","visit_dt": "2019-09-17"}'),
('{"id": "456","fname": "피터","lname": "윌리엄스","visit_dt": "2019-09-17"}');
-- 테이블 스트림에서 변경 데이터 캡처 레코드를 쿼리합니다. select * from rawstream1;
rawstream2에서 *를 선택하십시오.
system$stream_has_data('rawstream1') 조건이 false를 반환하면 작업은 어떻게 되나요?
-- 원시 JSON 데이터를 저장할 랜딩 테이블을 생성합니다.
-- Snowpipe는 이 테이블에 데이터를 로드할 수 있습니다. 원시 테이블 생성 또는 교체(var 변형)
-- 랜딩 테이블에 대한 삽입을 캡처하는 스트림을 생성합니다.
-- 작업은 이 스트림의 열 집합을 사용합니다. raw 테이블에서 rawstream1 스트림을 생성하거나 교체합니다.
-- 두 번째 스트림을 생성하여 랜딩 테이블에 대한 삽입을 캡처합니다.
-- 두 번째 작업은 이 스트림의 다른 열 집합을 사용합니다. raw 테이블에서 rawstream2 스트림을 생성하거나 교체합니다.
-- 원시 데이터에서 식별된 사무실 방문자의 이름을 저장하는 테이블을 생성합니다. 테이블 이름 생성 또는 교체(id int, first_name 문자열, last_name 문자열)
-- 원시 데이터에서 식별된 사무실 방문자의 방문 날짜를 저장하는 테이블을 생성합니다.
테이블 방문 생성 또는 교체(id int, dt date)
-- rawstream1 스트림의 새 이름 레코드를 이름 테이블에 삽입하는 작업을 만듭니다.
-- 스트림에 레코드가 포함된 경우 1분마다.
-- 'etl_wh' 웨어하우스를 귀하의 역할에 USAGE 권한이 있는 웨어하우스로 바꾸십시오. raw_to_names 작업 생성 또는 교체
창고 = etl_wh 일정 = '1분' 일 때
system$stream_has_data('rawstream1')
이름 n으로 병합
n.id = to_number(r1.id)에서 (rawstream1에서 var:id id, var:fname fname, var:lname lname 선택) r1 사용
일치하면 업데이트 세트 n.first_name = r1.fname, n.last_name = r1.lname
일치하지 않으면 (id, first_name, last_name) 값(r1.id, r1.fname, r1.lname)을 삽입합니다.
;
-- rawstream1 스트림의 방문 기록을 방문 테이블에 병합하는 또 다른 작업을 만듭니다.
-- 스트림에 레코드가 포함된 경우 1분마다.
-- 새 ID가 있는 기록이 방문 테이블에 삽입됩니다.
-- 방문 테이블에 존재하는 ID가 있는 레코드는 테이블의 DT 열을 업데이트합니다.
-- 'etl_wh' 웨어하우스를 귀하의 역할에 USAGE 권한이 있는 웨어하우스로 바꾸십시오. 작업 raw_to_visits 생성 또는 교체
창고 = etl_wh 일정 = '1분' 일 때
system$stream_has_data('rawstream2')
방문 v로 병합
(rawstream2에서 var:id id, var:visit_dt Visit_dt 선택) r2 on v.id = to_number(r2.id) 일치 시 v.dt = r2.visit_dt 설정 업데이트 사용
일치하지 않으면 (id, dt) 값(r2.id, r2.visit_dt)을 삽입합니다.
;
-- 두 작업을 모두 재개합니다.
작업 변경 raw_to_names 이력서;
작업 변경 raw_to_visits 이력서;
-- 랜딩 테이블에 레코드 집합을 삽입합니다. 원시에 삽입
값에서 parse_json(column1)을 선택하세요.
('{"id": "123","fname": "Jane","lname": "Smith","visit_dt": "2019-09-17"}'),
('{"id": "456","fname": "피터","lname": "윌리엄스","visit_dt": "2019-09-17"}');
-- 테이블 스트림에서 변경 데이터 캡처 레코드를 쿼리합니다. select * from rawstream1;
rawstream2에서 *를 선택하십시오.
ARA-C01 문제 77
COPY INTO 명령을 사용하여 성공적으로 로드한 후 스테이지에서 파일을 자동으로 삭제하려고 합니다.
삭제에 권장되는 접근 방식은 무엇입니까?
삭제에 권장되는 접근 방식은 무엇입니까?
ARA-C01 문제 78
Snowflake에서 트랜잭션 사용의 특징은 무엇입니까? (2개 선택).
ARA-C01 문제 79
다음 중 Snowflake 매개변수 계층 구조의 특징은 무엇입니까?
ARA-C01 문제 80
다음 개체를 눈송이로 복제할 수 있습니다.