全部产品
大数据操作系统
大数据操作系统 > 快速入门 > 实时数据处理 > 流式任务开发


操作步骤


提示：流任务所需资源在installer包的tool/support下。

1.下载storm流任务源码storm流任务源码，修改代码中SenqueceBolt类和RandomSpout类中的mysql的ip，数据库，用户及用户密码。修改完成后打成jar包。


2.登录mysql，选择配置的库，创建输入数据源input表：

CREATE TABLE input (

  id int,

  str varchar(50)

) ;

和输出数据源storm表：

CREATE TABLE storm (

  str varchar(50)

) ;

在input表中插入数据：

INSERT INTO `input` VALUES ('1', '{\"STATUS\":\"304\",\"name\":\"A1\",\"age\":\"16\",\"ip\":\"127.0.0.1\"}');

INSERT INTO `input` VALUES ('2', '{\"STATUS\":\"304\",\"name\":\"A1\",\"age\":\"16\",\"ip\":\"127.0.0.1\"}');

INSERT INTO `input` VALUES ('3', '{\"STATUS\":\"501\",\"name\":\"A2\",\"age\":\"16\",\"ip\":\"127.0.0.1\"}');

INSERT INTO `input` VALUES ('4', '{\"STATUS\":\"501\",\"name\":\"A2\",\"age\":\"16\",\"ip\":\"127.0.0.1\"}');

INSERT INTO `input` VALUES ('5', '{\"STATUS\":\"500\",\"name\":\"A3\",\"age\":\"16\",\"ip\":\"127.0.0.2\"}');

INSERT INTO `input` VALUES ('6', '{\"STATUS\":\"500\",\"name\":\"A3\",\"age\":\"16\",\"ip\":\"127.0.0.2\"}');

INSERT INTO `input` VALUES ('7', '{\"STATUS\":\"500\",\"name\":\"A3\",\"age\":\"16\",\"ip\":\"127.0.0.2\"}');

INSERT INTO `input` VALUES ('8', '{\"STATUS\":\"500\",\"name\":\"A3\",\"age\":\"16\",\"ip\":\"127.0.0.2\"}');

INSERT INTO `input` VALUES ('9', '{\"STATUS\":\"500\",\"name\":\"A3\",\"age\":\"16\",\"ip\":\"127.0.0.2\"}');

INSERT INTO `input` VALUES ('10', '{\"STATUS\":\"304\",\"name\":\"A1\",\"age\":\"16\",\"ip\":\"127.0.0.1\"}');

数据库请先授权。

grant all privileges on *.* to '用户名'@'ip' identified by '密码';

IP为要授权的(Worker Resources)IP地址


3. 导航至 流式任务开发>资源管理，点击新增，如下图所示：

1.png

图 资源管理


4.  点击新增后上传storm_demo jar 包，点击保存完成上传。如下图所示：

2.png

                                      图 资源上传


5. 同理上传实验所需要的依赖包commons-lang-2.6.jar和mysql-connector-java-5.1.34.jar，如下图所示：

3.png

图 资源管理


6. 上传完资源后，导航至流任务开发，点击新增，创建一个流任务，如下图所示：

4.png

图 流任务新增


7. 进入流任务编辑页，对页面进行编辑后运行，calss为count.FirstTopo，点击保存，完成流任务的创建，如下图所示：

5.png

图 流任务编辑页


8.在流任务开发页面点击启动按钮，启动创建好的流任务。如下图所示：

6.png

图 启动流任务


9. 启动成功后，导航至流任务监控，可以看到流任务的运行状态。如下图所示：

7.png

图 流任务监控页面


10. 查看storm表中的数据。如果有数据则成功。

8.png

                                              图 storm表数据


11.点击停止，停止流任务