1
내가 정기적으로 로그를 읽도록 Flume을 구성 할 수 있는지 또는 로그가 특정 크기에 도달했을 때 어떻게 알 수 있습니까? 미리 감사드립니다Flume - 정기적 인 간격으로 또는 특정 크기에 도달 할 때 로그를 읽는 방법
A
답변
1
로그를 정기적으로 읽는 flume 또는 로그가 특정 크기에 도달했을 때 어떻게 표시됩니까?
이 에이전트는 지속적으로 실행 중이며 이는 flume의 기능입니다. 그래서 어떤 간격 기록이나 메시지가오고 ... flume은 그걸 포착 할 수 있습니다.
들어오는 메시지 또는 로그의 크기를 확인하려면 FlumeSource 즉 (public class FlumeSource extends AbstractSource implements Configurable, EventDrivenSource)을 써야합니다. 그러면 원본에서 로그를 캡처하여 크기를 인쇄합니다. FileUtils 아파치 평민 클래스 & byteCountToDisplaySize입니다 당신이
LOG.info("Processing message...with size = " + FileUtils.byteCountToDisplaySize(bytes.length));
를 사용할 수있는 사람이 읽을 수있는 방법을 표시하기위한 것입니다.
이벤트 로그를 hbase로 serialize하려면 AsyncHbase API를 사용하여 사용자 지정 serializer를 작성할 수 있습니다.