top 5 buyers

top5buyers.usql

DECLARE @customerordersinput string = "/Data/Meny/Output/customerorders.csv";

DECLARE @cvsout string = "/Data/Meny/Output/top5buyers.csv";

@customersorders =
    EXTRACT CustomerId int,
	    CustomerFirstName string,
            CustomerLastName string,
            ProductName string,
            ProductPrice int,
	    Quantity int
    FROM @customerordersinput 
    USING Extractors.Csv(encoding: Encoding.UTF8);

@ds =
    SELECT c.CustomerId AS customerid, ANY_VALUE(c.CustomerFirstName) AS firstname, ANY_VALUE(c.CustomerLastName) AS lastname,  SUM(c.ProductPrice) AS total, COUNT(Quantity) AS NumberOfOrders
    FROM @customersorders AS c
    GROUP BY c.CustomerId
    ORDER BY total DESC
    FETCH 10 ROWS;  ;
    

OUTPUT @ds   
    TO @cvsout
      USING Outputters.Csv(encoding:Encoding.UTF8, quoting: false);