ステップ1。データをターゲットテーブルにコピーする

COPY INTO <テーブル> を実行して、ステージングされたデータをターゲット RAW_SOURCE テーブルにロードします。

注釈

データをテーブルにロードするには、ウェアハウスが必要です。前提条件の指示に従ってウェアハウスを作成した場合は、次の段落に進んでください。自動再開が構成されていないウェアハウスを使用している場合は、 ALTER WAREHOUSE を実行してウェアハウスを再開します。ウェアハウスの起動には最大5分かかることがあります。

ALTER WAREHOUSE mywarehouse RESUME;

次の COPY ステートメントは、前提条件スクリプトを使用して作成した外部ステージ上の特定のパスからデータをロードします。この例では、パスは2016年7月15日の17時間(5 PM)に書き込まれたデータをターゲットにしています。Snowflakeは各ファイルの ETag 値をチェックして、1回だけコピーされるようにします。このステートメントは、前提条件スクリプトを使用して作成したターゲット RAW_SOURCE テーブルへのパスにあるすべての新しいファイルをロードします。

COPY INTO raw_source
  FROM @my_stage/server/2.6/2016/07/15/15
  FILE_FORMAT = (TYPE = JSON);

raw_source テーブルは、 JSON データをタイプ VARIANT の単一の列に保存します。以下は、テーブルの現在のデータ構造です。列には、2つのイベントの単一バッチのデータが含まれます。この簡単な例では、 device_type および version キー値は特定のデバイスからのイベントのデータソースとバージョンを識別します。

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                                                                  |
| }                                                                                 |
+-----------------------------------------------------------------------------------+

次: ステップ2。クエリデータ