大数据技术之Flume 数据流监控——Ganglia 的安装与部署(11)

ops/2024/9/20 2:07:09/ 标签: 大数据, flume

目录

Flume 数据流监控

Ganglia 的安装与部署

Ganglia 组件介绍

1)安装 Ganglia

2)在 hadoop12 修改配置文件 /etc/httpd/conf.d/ganglia.conf

3)在 hadoop12 修改配置文件 /etc/ganglia/gmetad.conf

4)在 hadoop12, hadoop13, hadoop14 修改配置文件 /etc/ganglia/gmond.conf

5)在 hadoop12 修改配置文件 /etc/selinux/config

6)启动 Ganglia

7)打开网页浏览 Ganglia 页面

 操作 Flume 测试监控

1)启动 Flume 任务

2)发送数据观察 Ganglia 监测图

图例说明:


Flume 数据流监控

Ganglia 的安装与部署

Ganglia 组件介绍

  • gmond (Ganglia Monitoring Daemon): 轻量级服务,安装在每台需要收集指标的机器上,用于收集系统信息如 CPU 使用率、内存、磁盘、网络和活跃进程的数据等。
  • gmetad (Ganglia Meta Daemon): 整合所有信息,并将其以 RRD 格式存储至磁盘的服务。
  • gweb (Ganglia Web): Ganglia 的可视化工具,是一种利用浏览器显示 gmetad 所存储数据的 PHP 前端,在 Web 界面中以图表方式展现集群的运行状态下收集的多种不同指标数据。
1)安装 Ganglia
  • 规划

    • hadoop12: web, gmetad, gmond
    • hadoop13: gmond
    • hadoop14: gmond
  • 在 hadoop12, hadoop13, hadoop14 分别安装 epel-release

    [lzl@hadoop12 flume]$ sudo yum -y install epel-release
  • 在 hadoop12 安装

    [lzl@hadoop12 flume]$ sudo yum -y install ganglia-gmetad 
    [lzl@hadoop12 flume]$ sudo yum -y install ganglia-web
    [lzl@hadoop12 flume]$ sudo yum -y install ganglia-gmond
  • 在 hadoop13 和 hadoop14 安装

    [lzl@hadoop12 flume]$ sudo yum -y install ganglia-gmond
2)在 hadoop12 修改配置文件 /etc/httpd/conf.d/ganglia.conf
[lzl@hadoop12 flume]$ sudo vim /etc/httpd/conf.d/ganglia.conf

修改为:

# Ganglia monitoring system php web frontend#
Alias /ganglia /usr/share/ganglia
<Location /ganglia># Require local# 通过 windows 访问 ganglia,需要配置 Linux 对应的主机(windows)ip 地址Require ip 192.168.9.1# Require ip 10.1.2.3# Require host example.org
</Location>
3)在 hadoop12 修改配置文件 /etc/ganglia/gmetad.conf
[lzl@hadoop12 flume]$ sudo vim /etc/ganglia/gmetad.conf

修改为:

data_source "my cluster" hadoop12
4)在 hadoop12, hadoop13, hadoop14 修改配置文件 /etc/ganglia/gmond.conf
[lzl@hadoop12 flume]$ sudo vim /etc/ganglia/gmond.conf 

修改为:

cluster {name = "my cluster"owner = "unspecified"latlong = "unspecified"url = "unspecified"
}udp_send_channel {# 数据发送给 hadoop12host = hadoop12port = 8649ttl = 1
}udp_recv_channel {# 接收来自任意连接的数据bind = 0.0.0.0retry_bind = true
}
5)在 hadoop12 修改配置文件 /etc/selinux/config
[lzl@hadoop12 flume]$ sudo vim /etc/selinux/config

修改为:

# This file controls the state of SELinux on the system.
# SELINUX= can take one of these three values:
# enforcing - SELinux security policy is enforced.
# permissive - SELinux prints warnings instead of enforcing.
# disabled - No SELinux policy is loaded.
SELINUX=disabled# SELINUXTYPE= can take one of these two values:
# targeted - Targeted processes are protected,
# mls - Multi Level Security protection.
SELINUXTYPE=targeted

尖叫提示:SELinux 生效需要重启,如果此时不想重启,可以临时生效之:

[lzl@hadoop12 flume]$ sudo setenforce 0
6)启动 Ganglia
  • 在 hadoop12, hadoop13, hadoop14 启动

    [lzl@hadoop12 flume]$ sudo systemctl start gmond
  • 在 hadoop12 启动

    [lzl@hadoop12 flume]$ sudo systemctl start httpd
    [lzl@hadoop12 flume]$ sudo systemctl start gmetad
7)打开网页浏览 Ganglia 页面
http://hadoop12/ganglia

尖叫提示:如果完成以上操作依然出现权限不足错误,请修改 /var/lib/ganglia 目录的权限:

[lzl@hadoop12 flume]$ sudo chmod -R 777 /var/lib/ganglia

 操作 Flume 测试监控

1)启动 Flume 任务
[lzl@hadoop12 flume]$ bin/flume-ng agent \
-c conf/ \
-n a1 \
-f job/flume-netcat-logger.conf \
-Dflume.root.logger=INFO,console \
-Dflume.monitoring.type=ganglia \
-Dflume.monitoring.hosts=hadoop12:8649
2)发送数据观察 Ganglia 监测图
[lzl@hadoop12 flume]$ nc localhost 44444

   

图例说明:
字段(图表名称)字段含义
EventPutAttemptCountsource 尝试写入 channel 的事件总数量
EventPutSuccessCount成功写入 channel 且提交的事件总数量
EventTakeAttemptCountsink 尝试从 channel 拉取事件的总数量。
EventTakeSuccessCountsink 成功读取的事件的总数量
StartTimechannel 启动的时间(毫秒)
StopTimechannel 停止的时间(毫秒)
ChannelSize目前 channel 中事件的总数量
ChannelFillPercentagechannel 占用百分比
ChannelCapacitychannel 的容量

http://www.ppmy.cn/ops/105845.html

相关文章

酒店管理系统小程序(包含源码C++实现)

本文实现一个酒店管理系统小程序&#xff0c;涉及多个方面&#xff0c;包括用户接口、房间管理、预订系统、用户管理等。为了保持示例的简洁性&#xff0c;下面的实现将包括一个简单的控制台程序&#xff0c;演示基本的酒店管理功能。这将涵盖以下功能&#xff1a; 查看房间状…

设置Virtualbox虚拟机共享文件夹

由于工作环境的原因&#xff0c;选择Virtualbox的方式安装虚拟操作系统&#xff0c;常用的操作系统为ubuntu&#xff0c;不知道道友是否也曾遇到这样的问题&#xff0c;就是虚拟机和主机进行文件拖拽的时候&#xff0c;会因为手抖造成拖拽失败&#xff0c;虚拟机界面显示大个的…

JAVAEE初阶第一节——计算机的工作原理

系列文章目录 JAVAEE初阶第一节——计算机的工作原理 计算机的工作原理 计算机发展史冯诺依曼体系&#xff08;Von Neumann Architecture&#xff09;CPU操作系统&#xff08;Operating System&#xff09; 文章目录 系列文章目录JAVAEE初阶第一节——计算机的工作原理 计算机…

在.gitignore文件中重新添加或修改了忽略文件未生效的原因

因为git在初始化时就已经对忽略文件进行了不追踪&#xff0c;其它文件都会追踪&#xff0c;重新添加忽略文件后&#xff0c;实际上是没有进行更改追踪记录的&#xff0c;所以需要重新初始化。 git rm -r --cached .git add .git commit -m "Update .gitignore"

秋招突击——算法练习——8/30、9/4——技巧题练习——复习{}——新作{只出现一次的数字、多数元素、颜色分类、下一个排列、寻找重复数}

文章目录 引言复习新作136、只出现一次的数字个人实现 169、多数元素个人实现 75、颜色分类个人实现参考实现 31、下一个排列个人实现参考实现 287寻找重复数个人实现参考实现 总结 引言 手撕的代码大部分都是出自于这里&#xff0c;还是要继续加强&#xff0c;把剩下一些零碎…

Qt是不是经常写个QWidget输入参数?

发现Qt自带的一个输入控件QInputDialog类 QInputDialog类提供了一个简单方便的对话框&#xff0c;用于从用户获取单个值。 输入值可以是字符串、数字或列表中的项。必须设置一个标签来告诉用户他们应该输入什么。 提供了五个静态方便函数:getText()、getMultiLineText()、getI…

Java Lock 中使用 await() 和 signal()实现 wait()/notify()机制

** Java Lock 中使用 await() 和 signal()实现 wait()/notify()机制 ** 案例 import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock;public class MyService {private Lock lock new R…

5.8幂律变换

目录 示例代码1 运行结果1 示例代码2 运行结果2 补充示例原理 示例&#xff1a;使用cv::pow进行图像处理 代码 运行结果 ​编辑 补充 实验代码3 运行结果3​编辑 在OpenCV中&#xff0c;幂律变换&#xff08;Power Law Transformations&#xff09;是一种常用的图像…

一起学习LeetCode热题100道(63/100)

63.搜索插入位置(学习) 给定一个排序数组和一个目标值&#xff0c;在数组中找到目标值&#xff0c;并返回其索引。如果目标值不存在于数组中&#xff0c;返回它将会被按顺序插入的位置。 请必须使用时间复杂度为 O(log n) 的算法。 示例 1: 输入: nums [1,3,5,6], target 5…

Android 事件分发:为什么有时候会出现事件冲突?事件的顺序是如何的?出现事件冲突如何解决呢?比如为什么左右可以滑动,而上下却不行?

目录&#xff1a; 一、为什么要学习事件呢&#xff1f; 1.在开发复杂的应用时&#xff0c;经常需要处理复杂的用户交互逻辑。学习事件分发机制可以帮助你更好地控制事件的传递和处理流程&#xff0c;从而解决一些复杂的交互问题&#xff0c;如滑动冲突、点击穿透等。 2.面试需…

【ACM独立出版 | 厦大主办】第五届计算机科学与管理科技国际学术会议(ICCSMT 2024,10月18-20)

第五届计算机科学与管理科技国际学术会议(ICCSMT 2024) 定于2024年10月18-20日在中国厦门举行。 会议旨在为从事“计算机科学”与“管理科技”研究的专家学者、工程技术人员、技术研发人员提供一个共享科研成果和前沿技术&#xff0c;了解学术发展趋势&#xff0c;拓宽研究思路…

【LeetCode】两数之和

题目&#xff1a; 在数组中找到 2 个数之和等于给定值的数字&#xff0c;结果返回 2 个数字在数组中的下标。要求时间复杂度为 O(n)。 解题分析&#xff1a; 作者&#xff1a;halfrost 链接&#xff1a;https://leetcode.cn/leetbook/read/leetcode-cookbook/5lu4og/ 顺序扫描…

黑马头条docker启动minio访问不了,端口一直变化

原先代码为 docker run -p 9000:9000 --name minio -d --restartalways -e "MINIO_ROOT_USERminio" -e "MINIO_ROOT_PASSWORDminio123" -v /home/data:/data -v /home/config:/root/.minio minio/minio server /data 访问结果为&#xff0c;且9000会变为3…

Django+vue自动化测试平台(29)--测试平台集成playwright录制pytest文件执行

需求背景 一、 系统目标与功能概述 脚本管理: 系统需要能够组织和存储所有通过playwright官方插件录制的脚本。这包括脚本的上传、编辑、删除和版本控制功能。 脚本执行: 用户应该能够在后台界面上查看所有可用的脚本&#xff0c;并能够通过简单的点击操作来启动特定脚本的执…

pytest压力测试:不断发送数据,直到发现数据丢失

示例场景 假设有一个 send_data 函数接受数据并返回成功或失败的状态。 创建一个测试用例&#xff0c;通过逐步增加数据量来测试这个函数&#xff0c;直到返回失败为止。 步骤 定义压力测试函数 定义一个函数。不断发送数据&#xff0c;直到发现数据丢失。 创建 pytest 测试…

C#如何查看/写入日志到Windows事件查看器

Windows事件日志 Windows 操作系统将与计算机的系统性能、应用程序和安全方面相关的每个事件记录在 C:\WINDOWS\system32\winevt 的日志中。 事件查看器从这些原始事件日志中读取信息&#xff0c;然后以可读格式呈现信息。 打开Windows事件查看器的方法是 1、运行输入event…

Java字节码文件、组成、详解、分析;jclasslib插件、阿里arthas工具;Java注解

文章目录 一、字节码文件1.1 以正确的方式打开文件1.2 字节码文件的组成1.2.1 基础信息1.2.2 常量池1.2.3 方法 1.3 字节码常用工具1.4 总结 二、Java注解2.1 什么是Java注解2.2 注释和注解Annotation的区别&#xff08;掌握&#xff09;2.3 如何使用注解&#xff08;掌握&…

嵌入式硬件-ARM处理器架构,CPU,SOC片上系统处理器

多进程空间内部分布图&#xff1a;注意&#xff1a;创建线程实际使用堆区空间&#xff0c;栈区独立 ARM处理器架构&#xff1a; 基于ARM920T架构的CPU:以下为哈佛结构 ALU:算数运算器 R0~R12&#xff1a;寄存器 PC:程序计数器&#xff0c;默认为0&#xff0c;做自加运算&#x…

使用Java实现LRU缓存和LFU缓存

LRU缓存 问题描述 请你设计并实现一个满足 LRU (最近最少使用) 缓存 约束的数据结构。 实现 LRUCache 类&#xff1a; LRUCache(int capacity) 以 正整数 作为容量 capacity 初始化 LRU 缓存 int get(int key) 如果关键字 key 存在于缓存中&#xff0c;则返回关键字的值&…

【Kotlin设计模式】Kotlin实现外观模式

前言 外观模式&#xff08;Facade Pattern&#xff09;是一种结构型设计模式&#xff0c;旨在为子系统中的一组接口提供一个统一的接口。外观模式定义了一个高层接口&#xff0c;使得这一子系统更加容易使用。它将复杂的子系统封装在一个简单的接口后面&#xff0c;从而降低了客…