Etapa 1. Copiar dados para a tabela de destino¶
Execute COPY INTO <tabela> para carregar os dados preparados na tabela RAW_SOURCE de destino.
COPY INTO raw_source
FROM @my_stage/server/2.6/2016/07/15/15
FILE_FORMAT = (TYPE = JSON);
O comando copia todos os novos dados do caminho especificado no estágio externo para a tabela RAW_SOURCE de destino. Neste exemplo, o caminho especificado tem como alvo os dados gravados na 15ª hora (3 PM) de 15 de julho de 2016. Observe que o Snowflake verifica o valor S3 ETag de cada arquivo para garantir que ele seja copiado apenas uma vez.
Execute uma consulta SELECT para verificar se os dados foram copiados com sucesso.
SELECT * FROM raw_source;
A consulta retorna o seguinte resultado:
+-----------------------------------------------------------------------------------+
| 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 |
| } |
+-----------------------------------------------------------------------------------+
Nesta amostra de dados JSON, há dois eventos. Os valores de chave device_type e version identificam uma fonte de dados e uma versão para eventos de um dispositivo específico.
Próximo: Etapa 2. Consultar dados