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.
COPY INTO raw_source
FROM @my_stage/server/2.6/2016/07/15/15
FILE_FORMAT = (TYPE = JSON);
Der Befehl kopiert alle neuen Daten aus dem angegebenen Pfad des externen Stagingbereichs in die Zieltabelle RAW_SOURCE. In diesem Beispiel führt der Pfad zu Daten, die in der 15. Stunde (15:00 Uhr) des 15. Juli 2016 geschrieben wurden. Beachten Sie, dass Snowflake den S3 ETag-Wert jeder Datei überprüft, um sicherzustellen, dass sie nur einmal kopiert wird.
Führen Sie eine SELECT-Abfrage aus, um zu überprüfen, ob die Daten erfolgreich kopiert wurden.
SELECT * FROM raw_source;
Die Abfrage gibt das folgende Ergebnis zurück:
+-----------------------------------------------------------------------------------+
| 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 |
| } |
+-----------------------------------------------------------------------------------+
In diesen JSON-Beispieldaten gibt es zwei Ereignisse. Die Schlüsselwerte device_type und version identifizieren die Datenquelle und die Version von Ereignissen eines bestimmten Geräts:
Nächstes Thema: Schritt 2: Daten abfragen