Semaine 52 – intermédiaire

Lors du Snowflake Summit de juin 2023, les Dynamic Tables ont été l’une des grandes annonces.
Elles permettent de simplifier les pipelines par rapport aux tasks, streams et Materialized Views.

Nous aimerions que vous utilisiez notre procédure d’exemple ci-dessous pour relever rapidement ce défi ! La procédure crée une table si elle n’existe pas déjà et la remplit de données si elle existe déjà.
Parfait pour notre défi (et une fonction décente pour s’inspirer).

CREATE OR REPLACE PROCEDURE check_and_generate_data(tableName STRING)
RETURNS STRING
LANGUAGE JAVASCRIPT
EXECUTE AS CALLER
AS
$$
try {
var tableName = TABLENAME;
var command1 = `SELECT count(*) as count FROM information_schema.tables WHERE table_schema = CURRENT_SCHEMA() AND table_name = '${tableName.toUpperCase()}'`;
var statement1 = snowflake.createStatement({sqlText: command1});
var result_set1 = statement1.execute();

result_set1.next();
var count = result_set1.getColumnValue('COUNT');

if (count == 0) {
var command2 = `CREATE TABLE ${tableName} (payload VARIANT, ingested_at TIMESTAMP_NTZ default CURRENT_TIMESTAMP())`;
var statement2 = snowflake.createStatement({sqlText: command2});
statement2.execute();

return `Table ${tableName} has been created.`;
} else {
for(var i=0; i<40; i++) {
var jsonObject = {
"id": i,
"name": "Name_" + i,
"address": "Address_" + i,
"email": "email_" + i + "@example.com",
"transactionValue": Math.floor(Math.random() * 10000) + 1
};
var jsonString = JSON.stringify(jsonObject);

var command3 = `INSERT INTO ${tableName} (payload) SELECT PARSE_JSON(column1) FROM VALUES ('${jsonString}')`;
var statement3 = snowflake.createStatement({sqlText: command3});
statement3.execute();
}

return `40 records have been inserted into the ${tableName} table.`;
}

} catch (err) {
return "Failed: " + err;
}
$$;

Le défi de cette semaine consiste à créer une Dynamic Table pour obtenir les résultats suivants :