El Proyecto | Sobre nosotros | Contribuir | Donaciones | Licencia
HOME Mis cursos Finalizados
◄ Anterior
◄

Apache Flume

Siguiente ►
►

Introducción a Apache Flume

Apache Flume es un servicio distribuido y confiable para recopilar, agregar y mover grandes cantidades de datos de registro de múltiples fuentes a un almacenamiento centralizado. Es una herramienta esencial en el ecosistema Hadoop para la ingesta de datos en tiempo real.

Características Clave de Apache Flume

  • Distribuido y Escalable: Puede manejar grandes volúmenes de datos y escalar horizontalmente.
  • Fiabilidad y Tolerancia a Fallos: Garantiza la entrega de datos mediante mecanismos de confirmación y recuperación.
  • Flexibilidad: Soporta múltiples fuentes y destinos de datos.
  • Extensibilidad: Permite la personalización a través de interceptores y otros componentes.

Arquitectura de Apache Flume

La arquitectura de Flume se basa en tres componentes principales:

  1. Source (Fuente): Recibe datos de una fuente externa.
  2. Channel (Canal): Actúa como un buffer temporal para los datos.
  3. Sink (Sumidero): Envía los datos a su destino final.

Diagrama de Arquitectura de Flume

+---------+     +---------+     +---------+
| Source  | --> | Channel | --> |  Sink   |
+---------+     +---------+     +---------+

Componentes Adicionales

  • Agent (Agente): Un proceso de Flume que contiene una fuente, un canal y un sumidero.
  • Interceptors (Interceptores): Modifican o inspeccionan eventos en tránsito.

Configuración Básica de Apache Flume

Instalación de Apache Flume

  1. Descargar Flume:

    wget https://downloads.apache.org/flume/1.9.0/apache-flume-1.9.0-bin.tar.gz

  2. Extraer el archivo:

    tar -xzf apache-flume-1.9.0-bin.tar.gz

  3. Configurar las variables de entorno:

    export FLUME_HOME=/path/to/apache-flume-1.9.0
export PATH=$FLUME_HOME/bin:$PATH

Configuración de un Agente Flume

Un archivo de configuración de Flume define los agentes y sus componentes. Aquí hay un ejemplo básico:

# Nombre del agente
agent1.sources = source1
agent1.channels = channel1
agent1.sinks = sink1

# Configuración de la fuente
agent1.sources.source1.type = netcat
agent1.sources.source1.bind = localhost
agent1.sources.source1.port = 44444

# Configuración del canal
agent1.channels.channel1.type = memory
agent1.channels.channel1.capacity = 1000
agent1.channels.channel1.transactionCapacity = 100

# Configuración del sumidero
agent1.sinks.sink1.type = logger

# Conectar la fuente y el sumidero al canal
agent1.sources.source1.channels = channel1
agent1.sinks.sink1.channel = channel1

Ejecutar el Agente Flume

Para iniciar el agente Flume con la configuración anterior:

flume-ng agent --conf ./conf --conf-file example.conf --name agent1 -Dflume.root.logger=INFO,console

Ejemplo Práctico: Ingesta de Datos de Log

Paso 1: Configuración del Agente

Archivo de configuración log-agent.conf:

# Nombre del agente
logAgent.sources = logSource
logAgent.channels = logChannel
logAgent.sinks = hdfsSink

# Configuración de la fuente
logAgent.sources.logSource.type = exec
logAgent.sources.logSource.command = tail -F /var/log/syslog

# Configuración del canal
logAgent.channels.logChannel.type = memory
logAgent.channels.logChannel.capacity = 1000
logAgent.channels.logChannel.transactionCapacity = 100

# Configuración del sumidero
logAgent.sinks.hdfsSink.type = hdfs
logAgent.sinks.hdfsSink.hdfs.path = hdfs://namenode:8020/logs/
logAgent.sinks.hdfsSink.hdfs.fileType = DataStream
logAgent.sinks.hdfsSink.hdfs.writeFormat = Text
logAgent.sinks.hdfsSink.hdfs.batchSize = 1000
logAgent.sinks.hdfsSink.hdfs.rollSize = 0
logAgent.sinks.hdfsSink.hdfs.rollCount = 10000

# Conectar la fuente y el sumidero al canal
logAgent.sources.logSource.channels = logChannel
logAgent.sinks.hdfsSink.channel = logChannel

Paso 2: Ejecutar el Agente

flume-ng agent --conf ./conf --conf-file log-agent.conf --name logAgent -Dflume.root.logger=INFO,console

Ejercicio Práctico

Ejercicio 1: Configuración de un Agente Flume para Ingesta de Datos

Objetivo: Configurar un agente Flume que lea datos de un archivo de log y los escriba en HDFS.

Pasos:

  1. Crear un archivo de configuración para el agente.
  2. Configurar la fuente para leer de un archivo de log.
  3. Configurar el canal para usar memoria.
  4. Configurar el sumidero para escribir en HDFS.
  5. Ejecutar el agente y verificar que los datos se escriben en HDFS.

Solución:

Archivo de configuración file-to-hdfs.conf:

# Nombre del agente
fileAgent.sources = fileSource
fileAgent.channels = memChannel
fileAgent.sinks = hdfsSink

# Configuración de la fuente
fileAgent.sources.fileSource.type = exec
fileAgent.sources.fileSource.command = tail -F /path/to/logfile.log

# Configuración del canal
fileAgent.channels.memChannel.type = memory
fileAgent.channels.memChannel.capacity = 1000
fileAgent.channels.memChannel.transactionCapacity = 100

# Configuración del sumidero
fileAgent.sinks.hdfsSink.type = hdfs
fileAgent.sinks.hdfsSink.hdfs.path = hdfs://namenode:8020/logs/
fileAgent.sinks.hdfsSink.hdfs.fileType = DataStream
fileAgent.sinks.hdfsSink.hdfs.writeFormat = Text
fileAgent.sinks.hdfsSink.hdfs.batchSize = 1000
fileAgent.sinks.hdfsSink.hdfs.rollSize = 0
fileAgent.sinks.hdfsSink.hdfs.rollCount = 10000

# Conectar la fuente y el sumidero al canal
fileAgent.sources.fileSource.channels = memChannel
fileAgent.sinks.hdfsSink.channel = memChannel

Ejecutar el agente:

flume-ng agent --conf ./conf --conf-file file-to-hdfs.conf --name fileAgent -Dflume.root.logger=INFO,console

Conclusión

En esta sección, hemos aprendido sobre Apache Flume, su arquitectura y cómo configurarlo para la ingesta de datos. Hemos cubierto un ejemplo práctico de cómo configurar un agente Flume para leer datos de un archivo de log y escribirlos en HDFS. Con esta base, puedes explorar más configuraciones y personalizaciones para adaptarlas a tus necesidades específicas de ingesta de datos en tiempo real.

◄ Anterior
◄
Siguiente ►
►
El Proyecto | Sobre nosotros | Contribuir | Donaciones | Licencia
© Copyright 2026. Todos los derechos reservados