1단계. 데이터를 대상 테이블로 복사¶
COPY INTO <테이블> 을 실행하여 스테이징된 데이터를 대상 RAW_SOURCE 테이블에 로드합니다.
COPY INTO raw_source
FROM @my_stage/server/2.6/2016/07/15/15
FILE_FORMAT = (TYPE = JSON);
이 명령으로 외부 스테이지의 지정된 경로에서 대상 RAW_SOURCE 테이블로 새 데이터를 전부 복사합니다. 이 예에서 지정된 경로의 대상은 2016년 7월 15일 15시(3 PM)에 생성된 데이터입니다. Snowflake는 각 파일의 S3 ETag 값이 한 번만 복사되는지 확인합니다.
SELECT 쿼리를 실행하여 데이터가 성공적으로 복사되었는지 확인합니다.
SELECT * FROM raw_source;
쿼리에서 반환되는 결과는 다음과 같습니다.
+-----------------------------------------------------------------------------------+
| SRC |
|-----------------------------------------------------------------------------------|
| { |
| "device_type": "server", |
| "events": [ |
| { |
| "f": 83, |
| "rv": "15219.64,783.63,48674.48,84679.52,27499.78,2178.83,0.42,74900.19", |
| "t": 1437560931139, |
| "v": { |
| "ACHZ": 42869, |
| "ACV": 709489, |
| "DCA": 232, |
| "DCV": 62287, |
| "ENJR": 2599, |
| "ERRS": 205, |
| "MXEC": 487, |
| "TMPI": 9 |
| }, |
| "vd": 54, |
| "z": 1437644222811 |
| }, |
| { |
| "f": 1000083, |
| "rv": "8070.52,54470.71,85331.27,9.10,70825.85,65191.82,46564.53,29422.22", |
| "t": 1437036965027, |
| "v": { |
| "ACHZ": 6953, |
| "ACV": 346795, |
| "DCA": 250, |
| "DCV": 46066, |
| "ENJR": 9033, |
| "ERRS": 615, |
| "MXEC": 0, |
| "TMPI": 112 |
| }, |
| "vd": 626, |
| "z": 1437660796958 |
| } |
| ], |
| "version": 2.6 |
| } |
+-----------------------------------------------------------------------------------+
이 샘플 JSON 데이터에는 두 가지 이벤트가 있습니다. device_type 및 version 키 값은 특정 디바이스의 이벤트에 대한 데이터 소스 및 버전을 식별합니다.
다음 항목: 2단계. 데이터 쿼리