discuz论坛apache日志hadoop大数据分析项目：清洗数据核心功能解说及代码实现

discuz论坛apache日志hadoop大数据分析项目：清洗数据核心功能解说及代码实现 http://www.aboutyun.com/thread-8637-1-1.html (出处: about云开发)

我们在进行日志分析的时候，那么日志的数据是杂乱无章的，或则说日志的数据并不是我们都想看到的。所以我们需要对里面的数据进行清洗，说的直白一点就是要过滤里面的字符串。
下面便是我们需要过滤的数据：



这里如果对日志不了解或则不了解日志分析，可能会产生问题？为什么过滤这条数据，就能达到清洗的目的。这里所讲的只是核心内容，对于运行mapreduce来处理，可以看后面的文章。我这里重点讲如何把上面的数据，过滤出我们想要的数据。
我们需要什么数据，从about云分析discuz论坛apache日志hadoop大数据项目：概要设计说明书中，我们需要过滤出下面数据：



过滤分析
[align=left]
1.ip地址获取[/align]
[align=left]上面ip地址还是比较好过滤的，分隔符为- -即可得到我们想要的数据[/align]
[align=left]ipField = line.split("- -")[0].trim();[/align]

2.访问时间
访问时间，想获取时间容易，但是想做一个文艺程序员还是得费点功夫。
[01/Aug/2014:01:01:05 +0800] ，对于这个有的采用直接获取01/Aug/2014:01:01:05的这种方式，这种方式没有错，算是一个正常程序员所做的事 情。那么我们该怎么做的文艺优雅一点。这里是直接获取01/Aug/2014:01:01:05 +0800，这里是由相关函数的。

dt = new SimpleDateFormat("dd/MMM/yyyy:HH:mm:ss Z", Locale.US).parse(time);

复制代码

我们使用这个函数，将其转换为正常的时间格式。但是我们想要我们中国人能够一眼识别的正常时间。



如果你采用了这种形式20140801070458，这个既不是文艺程序员、也不是正常程序员所做的事情，就只剩下2比程序员这个职称了。
ok,下面我们做的文艺一点。
可是我们怎么才能得到下面时间，一个个进行组合，getYarn()+getMonth......等，完，又步入2比程序员的行列。

2014年8月1日 下午07时04分58秒

复制代码

这里介绍一个简单的方法

DateFormat df1 = DateFormat.getDateTimeInstance(DateFormat.LONG,DateFormat.LONG);

复制代码

dateField = df1.format(dt);

复制代码

这样就完美解决这个问题，不需要组合，只需要getDateTimeInstance传递参数即可，更多的时间格式参考Java新api获取年月日时分秒

3.url与浏览器的获取
这里面关键是对转义字符的理解正确，比如如何以双引号作为分隔符，如何以括号为分隔符。

解说完毕直接上代码：

package www.aboutyun.com;

import java.text.DateFormat;

import java.text.ParseException;

import java.text.SimpleDateFormat;

import java.util.Date;

import java.util.Locale;

public class test {

public static void StringResolves(String line) throws ParseException {

String ipField, dateField, urlField, browserField;

// 获取ip地址

ipField = line.split("- -")[0].trim();

// 获取时间,并转换格式

int getTimeFirst = line.indexOf("[");

int getTimeLast = line.indexOf("]");

String time = line.substring(getTimeFirst + 1, getTimeLast).trim();

Date dt = null;

DateFormat df1 = DateFormat.getDateTimeInstance(DateFormat.LONG,

DateFormat.LONG);

dt = new SimpleDateFormat("dd/MMM/yyyy:HH:mm:ss Z", Locale.US)

.parse(time);

dateField = df1.format(dt);

// 获取url

String[] getUrl = line.split("\"");

String firtGeturl = getUrl[1].substring(3).trim();

String secondGeturl = getUrl[3].trim();

urlField = firtGeturl + "分隔符" + secondGeturl;

// 获取浏览器

String[] getBrowse = line.split("\"");

String strBrowse = getBrowse[5].toString();

String str = "(KHTML, like Gecko)";

int i = strBrowse.indexOf(str);

strBrowse = strBrowse.substring(i);

String strBrowse1[] = strBrowse.split("\\/");

strBrowse = strBrowse1[0].toString();

String strBrowse2[] = strBrowse.split("\\)");

strBrowse = strBrowse2[1].trim();

System.out.println(ipField);

System.out.println(dateField);

System.out.println(urlField);

System.out.println(strBrowse);

}

public static void main(String[] args) throws ParseException {

// TODO Auto-generated method stub

String browser = "203.100.80.88 - - [01/Aug/2014:19:04:58 +0800] \"GET /uc_server/avatar.php?uid=3841&size=small HTTP/1.1\" 301 463 \"http://www.aboutyun.com/forum.php\" \"Mozilla/5.0 (Windows NT 6.2; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/28.0.1500.95 Safari/537.36 SE 2.X MetaSr 1.0";

test.StringResolves(browser );

}

}

运行结果如下：