日志存储与分析挖掘这一块是如何设计实现的？能否分享一下经验得失？谢谢！？

我们制定了统一的日志输出标准，让云上日志统一输出到stdout，我们通过fluentd实现日志收集，日志数据先入kafka，然后通过logstash清洗处理后，送到ES存储落地，同时通过flink 消费清洗后的Error日志，实现符合预定规则的异常告警，用户可以使用kibana进行初级的日志查询与挖掘分析。