Schritt 1: Daten in die Zieltabelle kopieren

Führen Sie COPY INTO <Tabelle> aus, um Ihre bereitgestellten Daten in die Zieltabelle RAW_SOURCE zu laden.

Bemerkung

Für das Laden von Daten in Tabellen ist ein Warehouse erforderlich. Wenn Sie ein Warehouse angelegt haben, indem Sie den in den Voraussetzungen beschriebenen Anweisungen gefolgt sind, können Sie diesen Absatz überspringen. Wenn Sie ein Warehouse verwenden, das nicht für die automatische Fortsetzung konfiguriert ist, führen Sie ALTER WAREHOUSE aus, um das Warehouse fortzusetzen. Beachten Sie, dass der Start des Warehouse bis zu fünf Minuten dauern kann.

ALTER WAREHOUSE mywarehouse RESUME;

Die folgende COPY-Anweisung lädt Daten von einem bestimmten Pfad in den externen Stagingbereich, den Sie mit dem vorbereiteten Skript erstellt haben. In diesem Beispiel führt der Pfad zu Daten, die in der 17. Stunde (5 PM) des 15. Juli 2016 geschrieben wurden. Snowflake überprüft den ETag-Wert jeder Datei, um sicherzustellen, dass diese nur einmal kopiert wird. Mit dieser Anweisung werden alle neuen Dateien im Pfad in die Zieltabelle RAW_SOURCE geladen, die Sie mit dem vorbereiteten Skript erstellt haben:

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

Die raw_source-Tabelle speichert Ihre JSON-Daten in einer einzigen Spalte vom Typ VARIANT. Nachfolgend sehen Sie die aktuelle Datenstruktur dieser Tabelle. Die Spalte enthält Daten für ein einzelnes Batch von zwei Ereignissen. In diesem einfachen Beispiel identifizieren die Schlüsselwerte device_type und version eine Datenquelle und Version von Ereignissen eines bestimmten Geräts:

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

Nächstes Thema: Schritt 2: Daten abfragen