Étape 1. Copie de données dans la table cible¶
Exécutez COPY INTO <table> pour charger vos données préparées dans la table cible RAW_SOURCE.
COPY INTO raw_source
FROM @my_stage/server/2.6/2016/07/15/15
FILE_FORMAT = (TYPE = JSON);
La commande copie toutes les nouvelles données du chemin spécifié sur la zone de préparation externe vers la table cible RAW_SOURCE. Dans cet exemple, le chemin spécifié cible les données écrites à la 15e heure (3 PM) du 15 juillet 2016. Notez que Snowflake vérifie la valeur ETag S3 de chaque fichier pour s’assurer qu’il n’est copié qu’une seule fois.
Exécutez une requête SELECT pour vérifier que les données ont bien été copiées.
SELECT * FROM raw_source;
La requête renvoie le résultat suivant :
+-----------------------------------------------------------------------------------+
| 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 |
| } |
+-----------------------------------------------------------------------------------+
Dans ces données JSON d’exemple, il y a deux événements. Les valeurs clés device_type, et version identifient une source de données et une version pour les événements d’un appareil spécifique.
Suivant : Étape 2. Interrogation de données