Semaine 81 – Intermédiaire

Saviez-vous qu’une tâche peut avoir plus d’un parent ?

Commencez par accéder au stage suivant, et exécutez directement le fichier qu’il contient avec EXECUTE IMMEDIATE.

CREATE STAGE frosty_aws_stage
URL = 's3://frostyfridaychallenges/';

Maintenant, vous devez créer 5 tâches :

La tâche 1 exécutera ce qui suit :

Task 1

INSERT INTO w81_raw_product (data)
SELECT parse_json(column1)
FROM
VALUES
('{"product_id": 21, "product_name": "Product U", "category": "Electronics", "price": 120.99, "created_at": "2024-02-16"}'),
('{"product_id": 22, "product_name": "Product V", "category": "Books", "price": 35.00, "created_at": "2024-02-16"}');
INSERT INTO w81_raw_customer (data)
SELECT parse_json(column1)
FROM
VALUES
('{"customer_id": 6, "customer_name": "Frank", "email": "frank@example.com", "created_at": "2024-02-16"}'),
('{"customer_id": 7, "customer_name": "Grace", "email": "grace@example.com", "created_at": "2024-02-16"}');
INSERT INTO w81_raw_sales (data)
SELECT parse_json(column1)
FROM
VALUES
('{"sale_id": 11, "product_id": 21, "customer_id": 6, "quantity": 1, "sale_date": "2024-02-17"}'), -- Nouveau produit, nouveau client
('{"sale_id": 12, "product_id": 22, "customer_id": 1, "quantity": 1, "sale_date": "2024-02-17"}'), -- Nouveau produit, client existant
('{"sale_id": 13, "product_id": 2, "customer_id": 7, "quantity": 2, "sale_date": "2024-02-17"}'), -- Produit existant, nouveau client
('{"sale_id": 14, "product_id": 3, "customer_id": 6, "quantity": 1, "sale_date": "2024-02-17"}'), -- Produit existant, nouveau client
('{"sale_id": 15, "product_id": 21, "customer_id": 5, "quantity": 1, "sale_date": "2024-02-17"}'); -- Nouveau produit, client existant;

Les tâches 2 à 4 analyseront le JSON des tables RAW. (C’est elles que vous voulez créer!)

La tâche 5 exécutera ce qui suit APRÈS que les tâches 2 à 4 aient été terminées :

Task 5

CREATE OR replace VIEW aggregated_sales
AS
SELECT c.customer_name,
p.product_name,
SUM(s.quantity) AS total_quantity,
SUM(s.quantity * p.price) AS total_sales
FROM sales s
join product p
ON s.product_id = p.product_id
join customer c
ON s.customer_id = c.customer_id
GROUP BY c.customer_name,
p.product_name

A la fin, vous devrez exécuter:

End run

SELECT t.name,
t.predecessors
FROM TABLE(information_schema.Task_dependents(task_name => 'INSERT_INTO_RAW', recursive => TRUE)) t;

Et obtenir:

Bon DAG!

Interactions du lecteur

Laisser un commentaire Annuler la réponse