Implementarea denormalizării datelor

În cele mai multe cazuri, tabelele de dimensiuni ar trebui să fie denormalizate. În acest exercițiu, vom folosi PySpark pentru a încărca două tabele de dimensiuni, products și categories, și vom denormaliza tabelul de produse înlocuind coloana categoryID cu categoryName corespunzătoare din tabelul categories.

Notă: Dacă primești o eroare legată de limita de rată a API-ului, aceasta apare de obicei pentru că o sarcină anterioară din Fabric nu s-a finalizat. Poți vizualiza sarcinile active din Fabric din pagina Monitor (situată în meniul vertical din stânga). Anularea sarcinilor vechi din pagina Monitor rezolvă de obicei această eroare.