全部产品
云市场

实施步骤

更新时间:2019-06-06 10:26:03

步骤一:创建OSS Schema和表

通过OSS建表向导或者手动编写SQL创建OSS Schema和表

本示例创建如下OSS Schema

  1. CREATE SCHEMA my_schema_name WITH DBPROPERTIES (
  2. CATALOG = 'oss',
  3. LOCATION = 'oss://bucket_name/workshop_sh/'
  4. );

创建交易记录表

  1. CREATE EXTERNAL TABLE tradelist_csv (
  2. t_userid STRING COMMENT '用户ID',
  3. t_dealdate STRING COMMENT '申请时间',
  4. t_businflag STRING COMMENT '业务代码',
  5. t_cdate STRING COMMENT '确认日期',
  6. t_date STRING COMMENT '申请日期',
  7. t_serialno STRING COMMENT'申请序号',
  8. t_agencyno STRING COMMENT'销售商编号',
  9. t_netno STRING COMMENT'网点编号',
  10. t_fundacco STRING COMMENT'基金账号',
  11. t_tradeacco STRING COMMENT'交易账号',
  12. t_fundcode STRING COMMENT'基金代码',
  13. t_sharetype STRING COMMENT'份额类别',
  14. t_confirmbalance DOUBLE COMMENT'确认金额',
  15. t_tradefare DOUBLE COMMENT'交易费',
  16. t_backfare DOUBLE COMMENT'后收手续费',
  17. t_otherfare1 DOUBLE COMMENT'其他费用1',
  18. t_remark STRING COMMENT'备注'
  19. )
  20. ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
  21. STORED AS TEXTFIlE
  22. LOCATION 'oss://bucket_name/workshop_sh/trade/';

创建开户信息表

  1. CREATE EXTERNAL TABLE userinfo (
  2. u_userid STRING COMMENT '用户ID',
  3. u_accountdate STRING COMMENT '开户时间',
  4. u_gender STRING COMMENT '性别',
  5. u_age INT COMMENT '年龄',
  6. u_risk_tolerance INT COMMENT '风险承受能力,1-10,10为最高级',
  7. u_city STRING COMMENT'所在城市',
  8. u_job STRING COMMENT'工作类别, A-K',
  9. u_income DOUBLE COMMENT'年收入(万)'
  10. )
  11. ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
  12. STORED AS TEXTFIlE
  13. LOCATION 'oss://bucket_name/workshop_sh/user/';

表创建成功后,可以执行SQL测试表数据是否正确。例如,查询交易机构SXS_0010,在0603至0604的100条交易记录。

  1. SELECT * FROM tradelist_csv
  2. WHERE t_cdate >= '2018-06-03' and t_cdate <= '2018-06-04' and t_agencyno = 'SXS_0010'
  3. limit 100;

测试表数据

步骤二:添加DLA数据源

注意:在添加数据源之前,需要将IP地址10.152.69.0/24,10.152.163.0/24,139.224.4.0/24加入DLA白名单。否则,Quick BI无法成功连接DLA,数据源也将添加失败。

添加dla数据源

配置项说明
显示名称为数据源设置一个名称,便于后续管理,可选项。
数据库地址DLA的连接地址,如何获取连接地址请参见查看服务访问点信息
端口DLA连接地址对应的端口号。
数据库DLA中Schema的名字。
用户名DLA中的账号,详情请参见账号和权限
密码DLA中账号对应的密码。

步骤三:创建数据集

例如,查询各城市、男性女性人群购买的基金总额(多表Join查询),数据集保存为citygender。数据源选择自定义SQL

  1. SELECT u_city, u_gender, SUM(t_confirmbalance) AS sum_balance
  2. FROM tradelist_csv , userinfo
  3. where u_userid = t_userid
  4. GROUP BY u_city, u_gender
  5. ORDER BY sum_balance DESC;

数据集

步骤四:创建仪表版

数据集选择citygender,分别选择值轴类别轴颜色分类,单击更新显示各城市男性、女性投资者购买基金的总额。

仪表板

接下来您可以根据需要在Quick BI中创建其他数据集、制作仪表盘。