É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.

Note

Le chargement des données dans des tables nécessite un entrepôt. Si vous avez créé un entrepôt en suivant les instructions énoncées dans les conditions préalables, passez au paragraphe suivant. Si vous utilisez un entrepôt qui n’est pas configuré pour la reprise automatique, exécutez ALTER WAREHOUSE pour reprendre l’entrepôt. Notez que le démarrage de l’entrepôt peut prendre jusqu’à cinq minutes.

ALTER WAREHOUSE mywarehouse RESUME;

L’instruction suivante COPY charge les données d’un chemin spécifique sur la zone de préparation externe que vous avez créée à l’aide du script requis. Dans cet exemple, le chemin cible les données écrites à la 17e heure (5 PM) du 15 juillet 2016. Snowflake vérifie la valeur ETag de chaque fichier pour s’assurer qu’elle n’est copiée qu’une seule fois. L’instruction charge tous les nouveaux fichiers dans le chemin vers la table cible RAW_SOURCE que vous avez créée à l’aide du script requis :

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

La table raw_source stocke vos données JSON dans une seule colonne de type VARIANT. Vous trouverez ci-dessous la structure de données actuelle de votre table. La colonne comprend des données d’un lot unique de deux événements. Dans cet exemple simple, les valeurs clé device_type et version identifient une source de données et une version pour les événements d’un appareil spécifique :

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

Suivant : Étape 2. Interrogation de données