小编use*_*557的帖子

cpan[1]> 安装 Crypt::SSLeay
阅读'/root/.cpan/sources/authors/01mailrc.txt.gz'
………………………………………………………………………………………………………………………………………………………… ..........................完毕
阅读'/root/.cpan/sources/modules/02packages.details.txt.gz'

数据库生成于 2012 年 8 月 6 日星期一 09:19:03 GMT
………………………………………………………………………………………………………………………………………………………… ..........................完毕

读取'/root/.cpan/sources/modules/03modlist.data.gz'

………………………………………………………………………………………………………………………………………………………… ………………

为模块 'Crypt::SSLeay' 运行安装
为 N/NA/NANIS/Crypt-SSLeay-0.64.tar.gz 运行 make
使用 LWP 获取：
http://mirror.cogentco.com/pub/CPAN/authors/id/N/NA/NANIS/Crypt-SSLeay-0.64.tar.gz

使用 LWP 获取：
http://mirror.cogentco.com/pub/CPAN/authors/id/N/NA/NANIS/CHECKSUMS

CPAN.pm 在这两个步骤中大约需要 15 分钟。我添加了更多的 URL 到urllist. 他们中的大多数使用 HTTP。

为什么这需要这么长时间，我怎样才能让它更快？

将BoltA和BoltB的输出发送到BoltC的最简单方法是什么.我是否必须使用联接或是否有任何更简单的解决方案.A和B具有相同的字段(ts,metric_name,metric_count).

    // KafkaSpout --> LogDecoder
    builder.setBolt(LOGDECODER_BOLT_ID, logdecoderBolt, 10).shuffleGrouping(KAFKA_SPOUT_ID);

    // LogDecoder --> CountBolt
    builder.setBolt(COUNT_BOLT_ID, countBolt, 10).shuffleGrouping(LOGDECODER_BOLT_ID);

    // LogDecoder --> HttpResCodeCountBolt
    builder.setBolt(HTTP_RES_CODE_COUNT_BOLT_ID, http_res_code_count_bolt, 10).shuffleGrouping(LOGDECODER_BOLT_ID);


    # And now I want to send CountBolt and HttpResCodeCountBolt output to Aggregator Bolt.

    // CountBolt --> AggregatwBolt
    builder.setBolt(AGGREGATE_BOLT_ID, aggregateBolt, 5).fieldsGrouping((COUNT_BOLT_ID), new Fields("ts"));

    // HttpResCodeCountBolt --> AggregatwBolt
    builder.setBolt(AGGREGATE_BOLT_ID, aggregateBolt, 5).fieldsGrouping((HTTP_RES_CODE_COUNT_BOLT_ID), new Fields("ts"));

这可能吗 ？

stats = {{'node100': {'load_1min': '0.58'}, 'node200': {'load_1min': '0.64'}, 'node28': {'load_1min': '0.69'}}

我想找到
1.具有最大Load_1min值的
键,2.具有最小Load_1min值的键,
3.用于统计数据的所有load_min键的avg值.

最后一个很简单 - 但前两个很难.我试过最大功能但失败了.