Опрацювання даних у Snowflake
Jake Roach
Field Data Engineer
Підзапити дають змогу використовувати результат одного запиту в іншому.
$$
$$
FROM ( ... ) або WHERE ... IN ( ... )

SELECT
...
-- Pull from query, not from a table
FROM (
-- Create a result set that will
-- be used by the main query
SELECT
<fields>
FROM <table>
WHERE ...
);
Отримуйте дані з результату іншого запиту, а не безпосередньо з таблиці.
$$
JOIN, WHERE тощоSELECT
month_num,
-- windchill - temperature has to be used twice here. What if this changes?
AVG(windchill - temperature) AS avg_differential
MIN(windchill - temperature) AS most_differential
FROM weather
WHERE
-- Filtering is taking place in the same query as aggregation/analysis
season = 'Winter' AND
temperature < 32
GROUP BY month_num;
-- Start with the subquery, then aggregateSELECT month_num, AVG(differential) AS avg_differential MIN(differential) AS most_differential FROM (SELECT month_num, windchill - temperature AS differential FROM weather WHERE season = 'Winter' AND temperature < 32) GROUP BY month_num;
| month_num | differential |
| --------- | ------------ |
| 12 | -12 |
| 1 | -3 |
| 1 | 0 |
| 2 | -7 |
| month_num | avg_differential | most_differential |
| --------- | ---------------- | ----------------- |
| 12 | -5.77 | -14 |
| 1 | -1.91 | -8 |
| 2 | -8.13 | -22 |
Після очищення даних аналіз легко читати й змінювати.
...
-- Filter by records with a value in
-- the subquery result set
WHERE <field> IN (
SELECT <other-field> FROM ...
);
Створіть невеликий набір результатів для трансформації, фільтрації чи обробки даних.
$$
IN у несталому наборі результатівAVG, MAX, MIN тощоSELECT
todays_date,
temperature,
status
FROM weather
WHERE todays_date IN ( -- Filter by all days with home games that were won
SELECT
game_date
FROM game_schedule
WHERE stadium = 'Home' AND did_win = TRUE
);

Опрацювання даних у Snowflake