keys表示生成key的列(可以直接使用行号或者使用Alias)，Map就是通过对keys的定义将key的列用特定的分割符串联起来形成新的key串，然后根据后面valueExpression的表达式获得value（表达式支持通过对列的简单（+-*/）的计算，也支持对于其他Reportentry的计算获得value）。

valueExpression是Recude的简单定义。当前抽象ReportEntryValueType定义的那些类型：min(取最小)，max(取最大)，sum（总和），average（平均），count(总次数)，plain(无需处理，这主要用于显示key那些列)。具体使用参看后面的配置说明。

conditions可以过滤不符合规则的输入。（支持简单的条件表达式组合）

valueFilter可以过滤计算后不符合定义的结果。（支持简单的条件表达式组合）

MapClass,MapParams,ReduceClass,ReduceParams是用于如果满足不了现有规则的情况下自定义Map,Reduce，需要实现对应的接口IReportMap或者IReportReduce。

Format可以对最后的结果在输出的时候格式化一下，当前只支持小数点round。

Report对象

包含了一个和多个ReportEntry对象，同时也支持在Report中定义ReportEntry对象（区别在于是否需要将这个ReportEntry共享给其他Report）。file指定了将会输出的文件名称。

Report Alert对象

报表的结果是一天的数据，只能做一些纵向比较，如果需要对多天的数据作横向比较以及趋势分析，就需要将多天的报表结合起来分析。具体配置也参见后面的数据定义。

分析流程抽象：

分析流程如下：

图3 分析流程抽象

流程中可以扩展的在第三步和第四步，第三步影响了Key的生成（当简单的列组合成字符串无法满足生成key的情况下可扩展），第四步影响value的生成。（当map的value生成以及Reduce无法满足需求的情况下可扩展），要使用min，max…以外的reduce，可以直接在ReduceClass中作处理，然后使用plain输出实现。

这种流程比传统的MapReduce的写法好处在于可以对输入只读取一次（海量的日志文件为了多种条件分析，反复读取本身就是最大的损耗）。可以看到在文件IO操作上，不会随着分析模型配置的增多而增长，中间数据也不会随着报表组合的不同而过快膨胀（只要报表复用Entry足够多）。

关键路径任务分割

分析过程生命周期定义：

图4 分析过程生命周期定义

各阶段设计描述:（这些阶段都是接口的方法定义）

配置解析：运行期载入,支持在线配置更新,提高系统灵活性。（本地或者URL资源）

获取分析列表：获取要分析的文件列表，并根据本地已有数据现状，选择性的生成需要获取的文件数据。

获取任务数据：从外部文件系统或者数据库获得数据。

切割任务数据文件：根据配置的文件块大小，将任务文件切割到合适的块。当前实现了实际切割和虚拟切割。TIPS:切割工作可以是并行多线程实现，实际切割是消耗CPU和内存的，特别是使用管道的方式，因此需要评估资源情况来开线程。虚拟切割，只是建立虚拟文件，定义好对应到实体文件的块起始。前者切割时候消耗较大，执行分析时分析线程干扰较小效率高，后者切割时无太大消耗，执行分析时会有干扰效率不是很高。（这个原因还没有细查，测试效果是这样）

分派任务并执行：单机多线程或者多机并行执行分析流程。由于单机会受到CPU和IO的限制，当到达一定数量线程以后，分析效率反而降低，因此才会有分布式的需求。

增量合并处理结果：分派好任务以后，多线程或者多机并性分析时，可以根据执行的情况部分增量式合并处理结果，当所有任务完成以后，结果合并结束。

输出分析结果：可以根据需求来创建报表格式。当前采用了csv的文件格式来创建报表，易于阅读和使用。同时也作了入库处理，也可以直接用Google Chart API创建图形化的Html。

输出对比告警：支持当日阀值预警，当日与昨日，当日与上周同期，当日与上月同期数据横向对比，到达阀值生成预警页面。

基于命令行方式执行阶段性任务

由于整个分析流程已经是任务化了，因此应用只需要具备命令接收功能就可以从任何一步开始执行分析流程，也可以选择执行到任何步骤直接返回或者输出中间结果。

当前应用启动通过监听端口数据包，接收命令并执行。

单任务并行处理化

希望通过并行化处理来提高效率，就必须要分析场景。

以下情况不适于用并行化执行来提高效率：

1．串行化任务。（上一个任务的输出成为下一个任务的输入，或者是有任务顺序的限制）

2．执行任务时有共享资源竞争。例如CPU,IO,网络等等，不是并行数越大越好，关键还是要看资源分配状况以及竞争状况。

3．并行化开销大于带来的收益。应用复杂度（并发控制），并行本身需要的资源消耗（计算能力，空间存储，带宽消耗等）较大。（在MapReduce中涉及到一点就是计算代价总是小于数据传输，因此让数据靠近计算，也就能极大提高效率，反过来看，如果为了分布式而将数据远离于计算，就得不偿失了）

4．流程瓶颈不在于当前并行处理的任务。也就是关键路径的问题。

在分析流程上，对于文件获取，文件切割，任务分析都是可以做并行化处理，但是还是要根据以上不适合的情况来考虑并行的规模和单机多线程或者多机多线程的方式来做，提升效率。

低耦合多机协作

图5 两种Master-Slave模式

上图画了两种Master-Slave模式，看起来没什么区别，但是箭头的方向不同带来的协作模式也有很大的区别。Hadoop Master负责维护任务的分派，任务执行监控，任务合并指派和监控的工作，而松散的M-S模式，Master处于被动状态，Master的设计更加简单化同时也增加了处理的灵活度。

用一种形象的描述来说明松散方式下的Master-Slave的协作模式。（就拿年底买火车票来说事）

1． Master要买去成都，武汉，长沙，北京，西安，广州的火车票各10张。（get Jobs）

2． SlaveA联系上Master要求领取任务，Master将买成都的火车票任务交给SlaveA，将任务标示为正在执行。(require job)

3． SlaveA自己托关系去开始买票。(do job)

4． SlaveB联系上Master要求领取任务，Master将买武汉的火车票任务交给SlaveB，将任务标示为正在执行。

5． SlaveB自己托关系开始买票。

6． ……

7． Master发现SlaveA在预期时间内还没有返回，将任务重置为未分配，允许其他Slave来获取任务。

8． SlaveB将买到的票给Master，Master将任务标示为完成，并且与其它已经完成的任务统计合并。

9． SlaveA返回，但是发现任务已经被别人完成，则无功而回。（计算资源被浪费）

10． Master发现所有任务已经完成，则向上级汇报，本次任务已经全部完成，输出结果。

其实从上面的描述可以看到Master设计十分简单，Slave功能也十分单一，带来的优势就是处理简单，易与管理，同时任何时候都允许新的Slave加入，充分利用资源。缺点就是可能在某些Slave不正常的时候不知情（浪费了部分时间），不过由于Master会有预期结果返回时间，因此这个时间设置小一些会减少浪费时间的场景，但也可能带来重复劳动的代价，这里可以通过算法来最大程度降低异常节点时间消耗，增加Slave有效工作。

Master职责：获取任务列表，分派任务，维护任务列表，合并分析结果，出最终结果报表。

Slave职责：请求任务，执行任务，返回分析结果。

下面两个图描述了具体的多机协作流程和任务状态转换情况。

图6 多机协作基本流程图

图7 任务状态转换图

附录

项目结构说明：

图8 项目包图

com.taobao.top.analysis：单机版和多机版的运行实例类在此包内。

com.taobao.top.analysis.data：抽象配置对象定义。

com.taobao.top.analysis.jobmanager：流程抽象接口和实现。

com.taobao.top.analysis.transport：NIO的底层通信实现。

com.taobao.top.analysis.map：Map接口定义和范例实现。

com.taobao.top.analysis.reduce：Reduce接口定义和范例实现。

com.taobao.top.analysis.util：工具类包。

com.taobao.top.analysis.worker：并行处理的工作者线程实现。

具体配置及说明：
top-report.xml

<?xml version="1.0" encoding="UTF-8"?>
<top_reports>

<global-condition value="$logflag$!=session"/>
    <global-condition value="$RECORD_LENGTH$>16&$RECORD_LENGTH$<26"/>

    


    <aliases>
    <alias name="logflag" key="1"/>

    <alias name="remoteIp" key="1"/>
    <alias name="partnerId" key="2"/>
    <alias name="format" key="3"/>
    <alias name="appKey" key="4"/>
    <alias name="apiName" key="5"/>
    <alias name="readBytes" key="6"/>
    <alias name="errorCode" key="7"/>
    <alias name="subErrorCode" key="8"/>
    <alias name="localIp" key="9"/>
    <alias name="nick" key="10"/>
    <alias name="version" key="11"/>
    <alias name="signMethod" key="12"/>

    <alias name="timestamp1" key="13"/>
    <alias name="timestamp2" key="14"/>
    <alias name="timestamp3" key="15"/>
    <alias name="timestamp4" key="16"/>
    <alias name="timestamp5" key="17"/>
    <alias name="timestamp6" key="18"/>

    <alias name="timestamp7" key="19"/>
    <alias name="timestamp8" key="20"/>
    <alias name="timestamp9" key="21"/>
    <alias name="timestamp10" key="22"/>
    <alias name="timestamp11" key="23"/>
    <alias name="timestamp12" key="24"/>
    <alias name="timestamp13" key="25"/>
    </aliases>

    
<entrys>
  <ReportEntry id="1" name="服务请求总次数" key="apiName" value="count()"/>
  <ReportEntry id="2" name="访问成功次数" key="apiName" value="count()" condition="$errorCode$=0" />
  <ReportEntry id="3" name="访问失败次数" key="apiName" value="count()" condition="$errorCode$!=0" />
  <ReportEntry id="4" name="业务平均处理时间" key="apiName" value="average($timestamp4$ - $timestamp3$)" valuefilter=">=0&<10000&isnumber&round:3"/>
  <ReportEntry id="5" name="TOP平均处理时间" key="apiName" value="average($timestamp6$ - $timestamp1$ - $timestamp4$ + $timestamp3$)" valuefilter=">=0&<10000&isnumber&round:3"/>
  <ReportEntry id="6" name="业务处理最小时间" key="apiName" value="min($timestamp4$ - $timestamp3$)" valuefilter=">=0&isnumber"/>
  <ReportEntry id="7" name="业务处理最大时间" key="apiName" value="max($timestamp4$ - $timestamp3$)" valuefilter=">=0&<10000&isnumber"/>
  <ReportEntry id="8" name="TIP服务调用前处理时间" key="apiName" value="average($timestamp3$ - $timestamp1$)" valuefilter=">=0&<10000&isnumber&round:3"/>
  <ReportEntry id="9" name="TIP服务调用后处理时间" key="apiName" value="average($timestamp5$ - $timestamp4$)" valuefilter=">=0&<10000&isnumber&round:3"/>
  <ReportEntry id="10" name="日志及输出消耗时间" key="apiName" value="average($timestamp6$ - $timestamp5$)" valuefilter=">=0&<10000&isnumber&round:3"/>
  <ReportEntry id="api_AverageSuccessTIPTimeConsume" name="成功请求TOP处理平均时间" key="apiName" condition="$errorCode$=0"
    value="average($timestamp6$ - $timestamp1$ - $timestamp4$ + $timestamp3$)" valuefilter=">=0&isnumber&round:3"/>
  <ReportEntry id="api_AverageFailTIPTimeConsume" name="失败请求TOP处理平均时间" key="apiName" condition="$errorCode$!=0"
   value="average($timestamp6$ - $timestamp1$ - $timestamp4$ + $timestamp3$)" valuefilter=">=0&isnumber&round:3"/>


  <ReportEntry id="11" name="访问总数" key="GLOBAL_KEY" value="count()" />
  <ReportEntry id="12" name="成功总数" key="GLOBAL_KEY" value="count()" condition="$errorCode$=0" />
  <ReportEntry id="13" name="失败总数" key="GLOBAL_KEY" value="count()" condition="$errorCode$!=0" />
  <ReportEntry id="14" name="业务平均消耗时间(ms)" key="GLOBAL_KEY" value="average($timestamp4$ - $timestamp3$)" valuefilter=">=0&<10000&isnumber&round:3"/>
  <ReportEntry id="15" name="TOP平均消耗时间(ms)" key="GLOBAL_KEY" value="average($timestamp6$ - $timestamp1$ - $timestamp4$ + $timestamp3$)" valuefilter=">=0&<10000&isnumber&round:3"/>


  <ReportEntry id="16" name="错误次数" key="errorCode" value="count()" condition="$errorCode$!=0" />


  <ReportEntry id="17" name="单机访问总量" key="localIp" value="count()" />
  <ReportEntry id="18" name="单机访问成功量" key="localIp" value="count()" condition="$errorCode$=0" />
  <ReportEntry id="19" name="单机访问失败量" key="localIp" value="count()" condition="$errorCode$!=0" />
  <ReportEntry id="20" name="单机业务平均消耗时间(ms)" key="localIp" value="average($timestamp4$ - $timestamp3$)" valuefilter=">=0&<10000&isnumber&round:3"/>
  <ReportEntry id="21" name="单机TOP平均消耗时间(ms)" key="localIp" value="average($timestamp6$ - $timestamp1$ - $timestamp4$ + $timestamp3$)" valuefilter=">=0&<10000&isnumber&round:3"/>


  <ReportEntry id="22" name="应用访问总量" key="appKey" value="count()" />
  <ReportEntry id="23" name="应用成功访问总量" key="appKey" value="count()" condition="$errorCode$=0" />
  <ReportEntry id="24" name="应用失败访问总量" key="appKey" value="count()" condition="$errorCode$!=0"/>
  <ReportEntry id="25" name="应用访问业务平均耗时(ms)" key="appKey" value="average($timestamp4$ - $timestamp3$)" valuefilter=">=0&<10000&isnumber&round:3"/>
  <ReportEntry id="26" name="应用访问TOP平均耗时(ms)" key="appKey" value="average($timestamp6$ - $timestamp1$ - $timestamp4$ + $timestamp3$)" valuefilter=">=0&<10000&isnumber&round:3"/>

  <ReportEntry id="27" name="时间段内访问总量" key="timestamp1" value="count()"
   mapClass="com.taobao.top.analysis.map.TimeMap"/>
  <ReportEntry id="28" name="时间段内访问成功总量" key="timestamp1" value="count()" condition="$errorCode$=0"
   mapClass="com.taobao.top.analysis.map.TimeMap"/>
  <ReportEntry id="29" name="时间段内访问失败总量" key="timestamp1" value="count()" condition="$errorCode$!=0"
   mapClass="com.taobao.top.analysis.map.TimeMap" valuefilter=">=0&isnumber&round:3"/>
  <ReportEntry id="30" name="时间段内访问业务平均耗时(ms)" key="timestamp1" value="average($timestamp4$ - $timestamp3$)"
   mapClass="com.taobao.top.analysis.map.TimeMap" valuefilter=">=0&isnumber&round:3"/>
  <ReportEntry id="31" name="时间段内访问TOP平均耗时(ms)" key="timestamp1" value="average($timestamp6$ - $timestamp1$ - $timestamp4$ + $timestamp3$)"
   mapClass="com.taobao.top.analysis.map.TimeMap" valuefilter=">=0&isnumber&round:3"/>


  <ReportEntry id="api_sysFailCount" name="TOP平台级错误量" key="apiName" value="count()"
     condition="$errorCode$<100&$errorCode$>0" />
  <ReportEntry id="api_serviceSysFailCount" name="服务系统级错误量(900到901)" key="apiName" value="count()"
     condition="$errorCode$<902&$errorCode$>899" />
  <ReportEntry id="api_serviceSysFailCount1" name="服务系统级错误量(大于901)" key="apiName" value="count()"
     condition="$errorCode$>901"/>
  <ReportEntry id="api_serviceAPIFailCount" name="服务业务级错误量" key="apiName" value="count()"
     condition="$errorCode$>100&$errorCode$<900"/>
  <ReportEntry id="api_serviceSysFailTotalCount" name="服务系统级总错误量" key="apiName" value="count()"
     condition="$errorCode$>899" />


</entrys>


<reports>
     <report id="0" file="totalTIPConsumeReport">
      <entryList>
    <entry name="TOP获取参数耗时" key="GLOBAL_KEY" value="average($timestamp7$)" condition="$errorCode$=0"/>
    <entry name="TOP获取参数最小耗时" key="GLOBAL_KEY" value="min($timestamp7$)" condition="$errorCode$=0"/>
    <entry name="TOP获取参数最大耗时" key="GLOBAL_KEY" value="max($timestamp7$)" condition="$errorCode$=0"/>

    <entry name="获取API信息耗时" key="GLOBAL_KEY" value="average($timestamp8$)" condition="$errorCode$=0"/>
    <entry name="获取API信息最小耗时" key="GLOBAL_KEY" value="min($timestamp8$)" condition="$errorCode$=0"/>
    <entry name="获取API信息最大耗时" key="GLOBAL_KEY" value="max($timestamp8$)" condition="$errorCode$=0"/>

    <entry name="处理协议必选参数耗时" key="GLOBAL_KEY" value="average($timestamp9$)" condition="$errorCode$=0"/>
    <entry name="处理协议必选参数最小耗时" key="GLOBAL_KEY" value="min($timestamp9$)" condition="$errorCode$=0"/>
    <entry name="处理协议必选参数最大耗时" key="GLOBAL_KEY" value="max($timestamp9$)" condition="$errorCode$=0"/>


    <entry name="频率黑名单校验耗时" key="GLOBAL_KEY" value="average($timestamp10$)" condition="$errorCode$=0"/>
    <entry name="频率黑名单校验最小耗时" key="GLOBAL_KEY" value="min($timestamp10$)" condition="$errorCode$=0"/>
    <entry name="频率黑名单校验最大耗时" key="GLOBAL_KEY" value="max($timestamp10$)" condition="$errorCode$=0"/>

    <entry name="协议可选参数校验耗时" key="GLOBAL_KEY" value="average($timestamp11$)" condition="$errorCode$=0"/>
    <entry name="协议可选参数校验最小耗时" key="GLOBAL_KEY" value="min($timestamp11$)" condition="$errorCode$=0"/>
    <entry name="协议可选参数校验最大耗时" key="GLOBAL_KEY" value="max($timestamp11$)" condition="$errorCode$=0"/>

    <entry name="业务必选参数校验耗时" key="GLOBAL_KEY" value="average($timestamp12$)" condition="$errorCode$=0"/>
    <entry name="业务必选参数校验最小耗时" key="GLOBAL_KEY" value="min($timestamp12$)" condition="$errorCode$=0"/>
    <entry name="业务必选参数校验最大耗时" key="GLOBAL_KEY" value="max($timestamp12$)" condition="$errorCode$=0"/>

    <entry name="业务可选参数校验耗时" key="GLOBAL_KEY" value="average($timestamp13$)" condition="$errorCode$=0"/>
    <entry name="业务可选参数校验最小耗时" key="GLOBAL_KEY" value="min($timestamp13$)" condition="$errorCode$=0"/>
    <entry name="业务可选参数校验最大耗时" key="GLOBAL_KEY" value="max($timestamp13$)" condition="$errorCode$=0"/>

    </entryList>
     </report>

  <report id="1" file="totalReport">
   <entryList>
    <entry id="11"/>
    <entry name="访问总流量(M)" key="GLOBAL_KEY" value="sum($readBytes$/#1000000#)" valuefilter=">=0&isnumber&round:4"/>
    <entry id="12"/>
    <entry name="访问成功率" key="GLOBAL_KEY" value="plain(entry(12)/entry(11))" valuefilter=">=0&isnumber&round:4"/>
    <entry id="13"/>
    <entry name="平台系统错误率(占总错误百分比)" key="GLOBAL_KEY" value="plain(entry(sysFailCount)/entry(13))" valuefilter=">=0&isnumber&round:4"/>
    <entry name="服务系统错误率(占总错误百分比)" key="GLOBAL_KEY" value="plain(entry(serviceSysFailCount)/entry(13))" valuefilter=">=0&isnumber&round:4"/>
    <entry name="服务业务错误率(占总错误百分比)" key="GLOBAL_KEY" value="plain(entry(serviceAPIFailCount)/entry(13))" valuefilter=">=0&isnumber&round:4"/>
    <entry id="14"/>
    <entry id="15"/>
    <entry name="TOP成功处理平均耗时" key="GLOBAL_KEY"
     value="average($timestamp6$ - $timestamp1$ - $timestamp4$ + $timestamp3$)" condition="$errorCode$=0" valuefilter=">=0&isnumber&round:3"/>
    <entry id="sysFailCount" name="平台系统错误数" key="GLOBAL_KEY" value="count()" condition="$errorCode$<100&$errorCode$>0"/>
    <entry id="serviceSysFailCount" name="服务系统错误数" key="GLOBAL_KEY" value="count()" condition="$errorCode$>899"/>
    <entry id="serviceAPIFailCount" name="服务业务错误数" key="GLOBAL_KEY" value="count()" condition="$errorCode$>100&$errorCode$<900"/>
   </entryList>
  </report>

  <report id="2" file="apiReport">
   <entryList>
       <entry name="服务名称" key="apiName" value="plain($apiName$)" />
    <entry id="1"/>
    <entry name="占总量比例" key="apiName" value="plain(entry(1)/entry(sum:1))" valuefilter=">=0&isnumber&round:3"/>
    <entry id="2"/>
    <entry name="服务请求成功率" key="apiName" value="plain(entry(2)/entry(1))" valuefilter=">=0&isnumber&round:3"/>
    <entry id="3"/>
    <entry id="4"/>
    <entry id="5"/>
    <entry name="TOP占总处理时间百分比" key="apiName" value="plain(entry(5)/entry(5+4))" valuefilter=">=0&isnumber&round:3"/>
    <entry id="api_AverageSuccessTIPTimeConsume"/>
    <entry id="api_AverageFailTIPTimeConsume"/>
    <entry id="6"/>
    <entry id="7"/>
    <entry id="8"/>
    <entry id="9"/>
    <entry id="10"/>
    <entry id="api_sysFailCount"/>
    <entry id="api_serviceSysFailTotalCount"/>
    <entry id="api_serviceAPIFailCount"/>
   </entryList>
  </report>

  <report id="3" file="errorCodeReport">
   <entryList>
       <entry id="33" name="错误码" key="errorCode" value="plain($errorCode$)" condition="$errorCode$!=0"/>
    <entry id="16"/>
    <entry name="错误比例" key="errorCode" value="plain(entry(16)/entry(sum:16))" condition="$errorCode$!=0" valuefilter=">=0&isnumber&round:3"/>
   </entryList>
  </report>

  <report id="4" file="machineReport">
   <entryList>
       <entry name="服务器IP" key="localIp" value="plain($localIp$)" />
    <entry id="17"/>
    <entry name="占总量比例" key="localIp" value="plain(entry(17)/entry(sum:17))" valuefilter=">=0&isnumber&round:3"/>
    <entry id="18"/>
    <entry name="成功率" key="localIp" value="plain(entry(18)/entry(17))" valuefilter=">=0&isnumber&round:3"/>
    <entry id="19"/>
    <entry id="20"/>
    <entry id="21"/>
    <entry name="TOP占总处理时间比值" key="localIp" value="plain(entry(21)/entry(20+21))" valuefilter=">=0&isnumber&round:3"/>
   </entryList>
  </report>

  <report id="5" file="appReport">
   <entryList>
       <entry name="应用ID" key="appKey" value="plain($appKey$)" />
    <entry id="22"/>
    <entry name="占总访问比例" key="appKey" value="plain(entry(22)/entry(sum:22))" valuefilter=">=0&isnumber&round:3"/>
    <entry id="23"/>
    <entry name="应用访问成功率" key="appKey" value="plain(entry(23)/entry(22))" valuefilter=">=0&isnumber&round:3"/>
    <entry id="24"/>
    <entry id="25"/>
    <entry id="26"/>
   </entryList>
  </report>

  <report id="6" file="periodReport">
   <entryList>
       <entry name="时间段" key="timestamp1" value="plain($timestamp1$)"
       mapClass="com.taobao.top.analysis.map.TimeMap"
       reduceClass="com.taobao.top.analysis.reduce.TimeReduce"/>
    <entry id="27"/>
    <entry name="占请求总量比例" key="timestamp1" value="plain(entry(27)/entry(sum:27))" valuefilter=">=0&isnumber&round:3"/>
    <entry id="28"/>
    <entry name="请求成功率" key="timestamp1" value="plain(entry(28)/entry(27))" valuefilter=">=0&isnumber&round:3"/>
    <entry id="29"/>
    <entry id="30"/>
    <entry id="31"/>
   </entryList>
  </report>

  <report id="7" file="appAPIReport">
   <entryList>
       <entry name="应用ID" key="appKey,apiName" value="plain($appKey$)" condition="$errorCode$=0"/>
       <entry name="服务名称" key="appKey,apiName" value="plain($apiName$)" condition="$errorCode$=0"/>
    <entry id="app_api_successCount" name="访问成功总量" key="appKey,apiName" value="count()" condition="$errorCode$=0"/>
   </entryList>
  </report>

  <report id="8" file="errorCodeAndSubErrorCodeReport">
   <entryList>
       <entry name="错误码" key="errorCode,subErrorCode" value="plain($errorCode$)" condition="$errorCode$!=0"/>
       <entry name="子错误码" key="errorCode,subErrorCode" value="plain($subErrorCode$)" condition="$errorCode$!=0"/>
    <entry name="错误总数" key="errorCode,subErrorCode" value="count()" condition="$errorCode$!=0"/>
   </entryList>
  </report>


  <report id="9" file="apiFailDetailReport">
   <entryList>
       <entry name="服务名称" key="apiName" value="plain($apiName$)" />
    <entry id="1"/>
    <entry id="3"/>
    <entry name="失败数占服务请求量比例" key="apiName" value="plain(entry(3)/entry(1))" valuefilter=">=0&isnumber&round:3"/>
    <entry name="失败数占失败总量比例" key="apiName" value="plain(entry(3)/entry(sum:3))" valuefilter=">=0&isnumber&round:3"/>
    <entry id="api_sysFailCount"/>
    <entry name="平台级错误占总服务请求比例" key="apiName" value="plain(entry(api_sysFailCount)/entry(1))" valuefilter=">=0&isnumber&round:3"/>
    <entry id="api_serviceSysFailCount"/>
    <entry name="服务系统级错误量(900到901)占总服务请求比例" key="apiName" value="plain(entry(api_serviceSysFailCount)/entry(1))" valuefilter=">=0&isnumber&round:3"/>
    <entry id="api_serviceSysFailCount1"/>
    <entry name="服务系统级错误量(大于901)占总服务请求比例" key="apiName" value="plain(entry(api_serviceSysFailCount1)/entry(1))" valuefilter=">=0&isnumber&round:3"/>
    <entry id="api_serviceAPIFailCount"/>
    <entry name="服务业务级错误占总服务请求比例" key="apiName" value="plain(entry(api_serviceAPIFailCount)/entry(1))" valuefilter=">=0&isnumber&round:3"/>
   </entryList>
  </report>

  <report id="10" file="appApiErrorReport">
   <entryList>
       <entry name="应用ID" key="appKey,apiName,errorCode" value="plain($appKey$)" condition="$errorCode$!=0"/>
       <entry name="服务名称" key="appKey,apiName,errorCode" value="plain($apiName$)" condition="$errorCode$!=0"/>
       <entry name="错误码" key="appKey,apiName,errorCode" value="plain($errorCode$)" condition="$errorCode$!=0"/>
    <entry name="错误次数" key="appKey,apiName,errorCode" value="count()" condition="$errorCode$!=0"/>
   </entryList>
  </report>

  <report id="11" file="verionAndSignTypeReport">
   <entryList>
       <entry name="版本号" key="version,signMethod" value="plain($version$)" condition="$errorCode$=0"/>
       <entry name="签名类型" key="version,signMethod" value="plain($signMethod$)" condition="$errorCode$=0"/>
       <entry name="访问成功总数" key="version,signMethod" value="count()" condition="$errorCode$=0"/>
   </entryList>
  </report>

  <report id="12" file="appErrorCodeReport">
   <entryList>
       <entry name="应用ID" key="appKey,errorCode" value="plain($appKey$)" condition="$errorCode$!=0"/>
       <entry name="错误码" key="appKey,errorCode" value="plain($errorCode$)" condition="$errorCode$!=0"/>
       <entry name="错误总数" key="appKey,errorCode" value="count()" condition="$errorCode$!=0"/>
   </entryList>
  </report>

</reports>

<alerts>
  
  <alert reportId="1" entryname="访问成功率" alerttype="now" valve="<0.9" />
  <alert reportId="1" entryname="访问总数" alerttype="day" valve="5000000" />
  <alert reportId="1" entryname="访问成功率" alerttype="day" valve="<0.01" />
  <alert reportId="1" entryname="平台系统错误率" alerttype="day" valve=">0.05" />
  <alert reportId="1" entryname="服务系统错误率" alerttype="day" valve=">0.05" />
  <alert reportId="1" entryname="服务业务错误率" alerttype="day" valve=">0.05" />
  <alert reportId="1" entryname="TOP平均消耗时间(ms)" alerttype="day" valve=">10" />
  <alert reportId="1" entryname="业务平均消耗时间(ms)" alerttype="day" valve=">10" />

  <alert reportId="2" keyentry="服务名称" entryname="占总量比例" alerttype="day" valve=">0.01" />
  <alert reportId="2" keyentry="服务名称" entryname="服务请求成功率" alerttype="day" valve="<0.01" />
  <alert reportId="2" keyentry="服务名称" entryname="业务平均处理时间" alerttype="day" valve=">20" />
  <alert reportId="2" keyentry="服务名称" entryname="TOP平均处理时间" alerttype="day" valve=">20" />

  <alert reportId="3" keyentry="错误码" entryname="错误比例" alerttype="day" valve=">0.01" />

  <alert reportId="4" keyentry="服务器IP" entryname="成功率" alerttype="day" valve="<0.01" />

  <alert reportId="5" keyentry="应用ID" entryname="占总访问比例" alerttype="day" valve="0.01" />
  <alert reportId="5" keyentry="应用ID" entryname="应用访问成功率" alerttype="day" valve="<0.05" />

  <alert reportId="7" keyentry="应用ID,服务名称" entryname="访问成功总量" alerttype="day" valve=">10000000" />

  <alert reportId="9" keyentry="服务名称" entryname="失败数占总量比例" alerttype="day" valve=">0.01" />

  <alert reportId="10" keyentry="应用ID,服务名称,错误码" entryname="错误次数" alerttype="day" valve=">10000" />

  <alert reportId="11" keyentry="版本号,签名类型" entryname="访问成功总数" alerttype="day" valve="<1000000" />

  <alert reportId="12" keyentry="应用ID,错误码" entryname="错误总数" alerttype="day" valve=">100000" />

</alerts>

</top_reports>

posted on 2010-01-12 21:58 岑文初阅读(3850) 评论(5) 编辑收藏

# re: 基于MapReduce的配置型日志分析组件 2010-01-17 01:31 ethan

目前的功能范围还比较窄(也许是我没看到)：
1.没有看到数据清洗(转换)处理流程，日志处理有时候需要对数据进行转换和容错；
2.对于TOP排名之类的应用还是有一定的问题；[如时间窗口随意的情况]
3.不太适合Distinct之类的应用；[这个目前你的需求里确实也没有]
4.没有看到权重设置(也就是资源占用)之类的内容,如max肯定比count计数之类的跑的慢;
5.没有看到com.taobao.top.analysis.worker中关于master节点对于并行队列的处理和涉及。很多时候容易碰到slave并行提交给master的场景(当你的任务设置过小的话)；
6.没有看到slave监控的涉及[尤其是多服务器的情况]。

TIPS1:日志拆分和slave的拆分是一个需要多次调优的过程

TIPS2:拆分工作我们做过测试，分别用shell(结合awk)、perl(crc32 hash)、java做过长时间的测试和代码优化(因为测试环境差别,不说详细的数据，拆分一个12GB的话单文件[60列，每行200个字节，拆分成50个小文件]，t(java)=3*t(shell),t(shell)=4*t(perl),t(*)代表时间消耗,但是perl拆分文件的占用cpu最高，一直在85%以上，perl的时间在4分钟左右)。回复更多评论

# re: 基于MapReduce的配置型日志分析组件 2010-01-17 12:14 岑文初

@ethan
1.condition和valuefilter就是数据清洗的环节，当然也支持，map和reduce的自定义。
2.对于top排名只需要定义order即可，当前流出了字段，不了解什么叫做时间窗随意。
3.没有这个需求，我不是做DB。
4.对于与处理来说由于对于记录输入只是一次遍历，因此没有必要再去细分什么类型的reduce，一条记录阅读完成以后这些分析必须全部做，这是一个串行的过程，因此无所谓前后之分。
5.松散的设计就是让master足够轻，同时任务slave就是资源廉价，通过用算法来分配任务，在失效时间和分配之间找到平衡点，master和slave的关系。
6.还是那个设计，如果master要监控slave，那么就不是我说的松散设计，而是传统的分布式mapreduce的思想。选择松散就是在控制度和复杂度之间找到平衡点。

对于处理来说就是需要找到关键路径，然后在关键路径上找各个环节可以优化并行处理的工作，至于如何优化，的却需要去验证，就好比文件切割和任务块执行，最简单的设计就是根据多核来设定单机的工作线程，因为这是消耗cpu的工作。

对于文件切割会根据采用的方式不同而不同，我只是关心java方式，呵呵，其他我不关心了，对于java我就用map file的方式来切割，管道输入输出效率还是很高的，我不了解你的测试用的是什么方式。

不过很感谢你的留言，起码看到有人还是看了，呵呵。回复更多评论

# re: 基于MapReduce的配置型日志分析组件 2010-01-17 15:18 ethan

@岑文初
1.时间窗口随意指的是如1/1日的top 10,1/2的top 10,1/1-1/3的top 10.可以随意做时间窗口设计。
2.Distinct 之类的应用并不只是数据库专属应用。如使用用户数就是一个distinct的典型应用，一个用户本月使用三次，在本月使用用户数指标中只能有算一个。延展开来就是网站中常用的独立访问用户数的概念。
3.关于master端队列的设计是可以保证slave在并行提交数据给master的时候能保证正常处理。[因为你的设计中是slave主动将合并结果给master，不是master去取,hadoop没有这样的问题]
------------

我很想了解一下你所说的map file方式文件拆分的性能测试数据和实现方式。
在大数据量话单和日志分析系统中，拆分是保证时效性和性能中最重要的一环。回复更多评论

# re: 基于MapReduce的配置型日志分析组件 2010-01-18 13:39 岑文初

@ethan
1.对于趋势统计我们现在是将每日数据入库来做更加个性化的统计，因为分析后的数据已经是比较粗粒度，但是同时有能够满足个性化需求的，因此就不再这个系统中设计了。当然趋势告警这边有做
2.先不说月，我在系统中有max,min,average，其实就有一定的这个意思，当着些逻辑满足不了，可以自动扩展reduce的方法来实现。
3.对于结果的merge是master单线程做的，多线程提交只是放在合并队列，因此不存在并发问题。而且合并结果本来就有资源竞争，对于此类过程，多线程和单线程效率没什么区别，多线程反而增加复杂度。

mapping file其实就是用java的管道和内存文件来做的，效率应该说在java中比较好了，实际的测试我到没有准确的做过，也不好给出结果。

当前正在做即时分析，数据源也可以切换到DB上去了，时间可以缩短，省掉了对大文件切割和拖拉的时间。（这块时间的却是在分析中最耗时的），这样我除了每天的日报表，也有了段时间的报表（每15分钟，自己可以定义时间段），增量合并后就是一天的报表。回复更多评论

# re: 基于MapReduce的配置型日志分析组件 2010-01-19 18:19 Ethan

@岑文初
我们目前的系统分为两个部分
1.下载文件 -->切割-->逻辑处理(比较复杂的逻辑)-->合并(很简单的合并，电信行业有历史记录查询需求)-->加载入库
2.数据库-->切割(hash)-->统计报表预处理-->报表

有两次切割。回复更多评论

新用户注册刷新评论列表


只有注册用户登录后才能发表评论。




网站导航: 博客园 IT新闻知识库 C++博客博问管理

放翁（文初）的一亩三分地

常用链接

留言簿(34)

随笔档案

淘宝同学的blog

搜索

最新评论

阅读排行榜

评论排行榜

需求场景

组件功能设计关键点

设计点分析

分析模型抽象

分析实体抽象：