ステップ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 値をチェックして、ファイルが1回だけコピーされるようにすることに注意してください。
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 データには、2つのイベントがあります。 device_type
および version
キー値は特定のデバイスからのイベントのデータソースとバージョンを識別します。
次: ステップ2。クエリデータ