公司要做网站,怎么做网站支付,网站设计费 建设费入什么科目,旅游网站设计方案Prometheus负责集群数据的监控和采集#xff0c;然后传递给grafana进行可视化#xff0c;集成睿象云可实现监控报警#xff0c;为了方便操作#xff0c;可以通过iframe嵌套grafana到指定的页面。 文章目录 1.Grafana集成Prometheus2.iframe内嵌grafana3.监控告警 1.Grafana… Prometheus负责集群数据的监控和采集然后传递给grafana进行可视化集成睿象云可实现监控报警为了方便操作可以通过iframe嵌套grafana到指定的页面。 文章目录 1.Grafana集成Prometheus2.iframe内嵌grafana3.监控告警 1.Grafana集成Prometheus
修改prometheus/config/prometheus.yml,配置需要监控的集群节点(doirs,zookeeper,hadoop,flink)。
修改完配置重启docker。
访问http://ip地址:9090/targets可以看到集群各个节点的健康状态。 访问http://ip地址:3000/dashboards Connections-Data sources添加prometheus数据源然后新建仪表盘 根据id加载对应的仪表盘 flink集群 doris集群 hadoop集群 zookeeper集群 2.iframe内嵌grafana
修改grafana/conf/grafana.ini设置匿名登录。 设置允许嵌套图表。
复制面板的链接 内嵌到指定的网页
3.监控告警
grafana集成睿象云可以实现邮箱钉钉短信和电话等方式告警以监控flink集群告警邮箱为例进入睿象云绑定邮箱。 监控grafana 得到url链接 到grafana添加联系点 设置分配策略及通知策略 添加仪表盘表达式((flink_jobmanager_job_uptime)-(flink_jobmanager_job_uptime offset 30s))/100用于监控flink集群作业是否正常运行flink_jobmanager_job_uptime表示job从启动到当前时间的持续运行时间若当前时间戳减去前30s的时间戳等于0说明运行的job已经挂掉了 告警条件设置为当前时刻表达式的取值为0 设置联系点 正常情况下的监控 验证监控告警是否有效
public static void main(String[] args) throws Exception {StreamExecutionEnvironment env StreamExecutionEnvironment.getExecutionEnvironment();env.setParallelism(1);SingleOutputStreamOperatorWordCount sensorDS env.socketTextStream(192.168.235.130, 9988).map(new MapFunctionString, WordCount() {Overridepublic WordCount map(String s) throws Exception {String[] data s.split(,);return new WordCount(data[0], Integer.parseInt(data[1]));}});KeyedStreamWordCount, String sensorKS sensorDS.keyBy(sensor - sensor.getWord());WindowedStreamWordCount, String, TimeWindow sensorWS sensorKS.window(TumblingProcessingTimeWindows.of(Time.seconds(10)));SingleOutputStreamOperatorString process sensorWS.process(new ProcessWindowFunctionWordCount, String, String, TimeWindow() {Overridepublic void process(String s, Context context, IterableWordCount elements, CollectorString out) throws Exception {long startTs context.window().getStart();long endTs context.window().getEnd();String windowStart DateFormatUtils.format(startTs, yyyy-MM-dd HH:mm:ss.SSS);String windowEnd DateFormatUtils.format(endTs, yyyy-MM-dd HH:mm:ss.SSS);long count elements.spliterator().estimateSize();out.collect(key s 的窗口[ windowStart , windowEnd )包含 count 条数据 elements.toString());}});process.print();env.execute();}当断开端口的监听之后job挂掉了此时邮箱收到告警信息。
