ASP源码.NET源码PHP源码JSP源码JAVA源码DELPHI源码PB源码VC源码VB源码Android源码
当前位置:首页 >> 数据库 >> MySql >> 104-storm 整合 kafka之保存MySQL数据库

104-storm 整合 kafka之保存MySQL数据库(3/3)

来源:网络整理     时间:2015-10-08     关键词:Exception,zookeeper

本篇文章主要介绍了"104-storm 整合 kafka之保存MySQL数据库",主要涉及到Exception,zookeeper方面的内容,对于MySql感兴趣的同学可以参考一下: 整合KafkaStorm,消息通过各种方式进入到Kafka消息中间件,比如通过使用Flume来收集的日志数据,然后暂由Kafka中的路由暂存,然后在由实时计算程...

if (m.find()) {
     url = m.group(1);
     usetime = m.group(2);
     currentTime = m.group(3);
     System.out.println(url + "->" + usetime + "->" + currentTime);

     MyDbUtils.update(MyDbUtils.INSERT_LOG, url, usetime,
               MyDateUtils.formatDate2(new Date(Long.parseLong(currentTime))));
}


(4)统计指标

--统计每个url平均响应时间
SELECT
  topdomain,
  ROUND(AVG(usetime) / 1000, 2) avg_use_time
FROM
  log_info
GROUP BY topdomain;

104-storm 整合 kafka之保存MySQL数据库

以上就介绍了104-storm 整合 kafka之保存MySQL数据库,包括了Exception,zookeeper方面的内容,希望对MySql有兴趣的朋友有所帮助。

本文网址链接:http://www.codes51.com/article/detail_187461_3.html

相关图片

相关文章