步骤3：数据开发处理

评分最高Top10电影的计算方法是：先计算出每部电影的总评分和参与评分的用户数，过滤掉参与评分的用户数小于3的记录，返回电影名称、平均评分和参与评分用户数。

1. 登录DataArts Studio管理控制台。

   详情请参考访问DataArts Studio实例控制台。

2. 在DataArts Studio控制台首页，选择对应工作空间的“数据开发”模块，进入数据开发页面。
3. 创建一个DWS SQL脚本，以通过DWS SQL语句来创建数据表。
   图1 新建脚本
   

4. 在新建脚本弹出的SQL编辑器中，填写关键参数。

   表1 关键参数

   参数	说明
   数据连接	步骤5中创建的DWS数据连接。
   数据库	步骤7中创建的数据库。

   图2 关键参数
   
   输入如下SQL语句，单击“运行”，从movies_item和ratings_item表中计算出评分最高的Top10电影，将结果存放到top_rating_movie表。

   SET
       SEARCH_PATH TO dgc;
   insert
       overwrite into top_rating_movie
   select
       a.movieTitle,
       b.ratings / b.rating_user_number as avg_rating,
       b.rating_user_number
   from
       movies_item a,
       (
           select
               movieId,
               sum(rating) ratings,
               count(1) as rating_user_number
           from
               ratings_item
           group by
               movieId
       ) b
   where
       rating_user_number > 3
       and a.movieId = b.movieId
   order by
       avg_rating desc
   limit
       10

   图3 脚本（top_rating_movie）
   

5. 脚本调试无误后，单击“保存并提交版本”提交该脚本，脚本名称为“top_rating_movie”。后续开发并调度作业引用该脚本。
6. 脚本保存完成且运行成功后，可以参考步骤3新建DWS SQL脚本，执行如下SQL语句查看top_rating_movie表数据。您还可以参考图4，下载或转储表数据。

   SET SEARCH_PATH TO dgc;
   SELECT * FROM top_rating_movie

   图4 查看top_rating_movie表数据
   

最活跃Top10电影的计算方法是：平均评分大于3.5的电影中用户评分数最多的10部电影。

1. 登录DataArts Studio管理控制台。

   详情请参考访问DataArts Studio实例控制台。

2. 在DataArts Studio控制台首页，选择对应工作空间的“数据开发”模块，进入数据开发页面。
3. 创建一个DWS SQL脚本，以通过DWS SQL语句来创建数据表。
   图5 新建脚本
   

4. 在新建脚本弹出的SQL编辑器中，填写关键参数。

   表2 关键参数

   参数	说明
   数据连接	步骤5中创建的DWS数据连接。
   数据库	步骤7中创建的数据库。

   图6 关键参数
   
   输入如下SQL语句，单击“运行”，从movies_item和ratings_item表中计算出最活跃的Top10电影，将结果存放到top_active_movie表。

   SET
       SEARCH_PATH TO dgc;
   insert
       overwrite into top_active_movie
   select
       *
   from
       (
           select
               a.movieTitle,
               b.ratingSum / b.rating_user_number as avg_rating,
               b.rating_user_number
           from
               movies_item a,
               (
                   select
                       movieId,
                       sum(rating) ratingSum,
                       count(1) as rating_user_number
                   from
                       ratings_item
                   group by
                       movieId
               ) b
           where
               a.movieId = b.movieId
       ) t
   where
       t.avg_rating > 3.5
   order by
       rating_user_number desc
   limit
       10

   图7 脚本（top_active_movie）
   

5. 脚本调试无误后，单击“保存并提交版本”提交该脚本，脚本名称为“top_active_movie”。后续开发并调度作业引用该脚本。
6. 脚本保存完成且运行成功后，可以参考步骤3新建DWS SQL脚本，执行如下SQL语句查看top_active_movie表数据。您还可以参考图8，下载或转储表数据。

   SET SEARCH_PATH TO dgc;
   SELECT * FROM top_active_movie

   图8 查看top_active_movie表数据