基于云服务创建实时运营数据分析服务

实时运营数据分析

使用数据计算服务、流数据总线、流计算产品，可对实时业务数据进行归档和分析，实现秒级响应，对接数据大屏或BI报表产品即刻呈现业务状态。

使用京东云的流数据总线、流计算以及数据大屏，对于其他云平台可做参考。

流数据总线是面向大数据场景下可扩展、分布式、高吞吐量的消息服务，提供低延迟的消息发布及订阅功能，帮助用户快速构建流式数据的分析和应用。

流计算是大数据场景下的实时数据处理与分析平台，支持用户以 SQL 方式编写数据处理作业, 降低流式数据开发门槛，帮助用户快速构建流处理应用。

京东云数据大屏是一款基于实时多层渲染技术的数据可视化工具，它能够提供对海量数据进行实时场景化展示，同时还提供数据分层展示功能，用户可以通过钻取、缩放等交互方式全面的掌握数据。

创建“流计算”应用，进行数据输入和输出，使用作业开发

1.登录“流计算”控制台，进入流计算的“应用管理”页面，创建应用。

2.点击“创建应用”创建应用。选择地域为华北-北京，输入应用名称“lab_rtd01”，其他根据业务需求选择或者为默认。

3.点击确认“lab_rtd01”应用创建完成。

4.在应用列表页，点击已创建的应用名称“lab_rtd01”后，进入到作业开发页面。

5.点击“创建”后进入输入源定义页面。按照要求填写“名称”为“lab_rtdin01”，选择已经创建好的“源类型”、“流式数据”、“主题”。按照需求配置“Batch Interval”。“消息识别模式”这里选择JSON来演示。

6.接下来配置JSON格式的“消息样例”，“字段设置方式”可以选择手动或自动。字段设置的数据类型需要手动选择。“{“province_id”:“1”,“province_name”:“北京”,“province_code”:“110000”,“province_sale”:“10003”}”

7.点击确认完成输入设置，控制台弹出“添加成功”。

8.选择返回作业开发页面，可以查看创建的“lab_rtdin01”。点击左侧“输出”，进入到输出模块。

9.点击“创建”后进入输出位置定义页面。按照要求填写“名称”为“lab_rtdout01”，选择已经创建好的“输出位置”、“数据库”、“数据表”。这里演示选择“忽略异常数据处理，不保存”。

10.点击确认完成输出设置，控制台弹出“保存成功”。

11.在作业开发页面，点击左侧“查询”，进入到查询模块。

12.点击“创建”后进入查询定义页面。填写查询“名称”为“lab_rtdout01”，按照项目需求选择分配资源。

13.点击确认完成查询创建，控制台弹出“操作成功”。

14.完成查询创建后，会跳转作业开发设置界面，也可以手动点击查询名称进入。在开发方式下面写入“insert into table lab_rtdout01 select province_code,province_name,province_sale from lab_rtdin01; ”。

15.点击“保存”作业开发设在后，自动返回查询模块页面。“状态”默认显示已停用。

16.点击“启用”开启作业开发任务，显示正在提交，等待开启。“状态”为启用时，表示成功。