From efb33bfc59f50c213bbdad2353e4525508a90c42 Mon Sep 17 00:00:00 2001 From: Avishai Ish-Shalom Date: Tue, 14 Oct 2014 06:14:42 +0300 Subject: [PATCH] Fixed #18 filter out pika logs from AMQPHandler --- logstash/handler_amqp.py | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/logstash/handler_amqp.py b/logstash/handler_amqp.py index ad984db..c8ca4ec 100644 --- a/logstash/handler_amqp.py +++ b/logstash/handler_amqp.py @@ -7,6 +7,11 @@ import pika from logstash import formatter +class PikaLogFilter(Filter): + """A log filter which filters out pika logs""" + def filter(self, record): + return not record.name.split(".")[0] == "pika" + class AMQPLogstashHandler(SocketHandler, object): """AMQP Log Format handler @@ -67,6 +72,7 @@ def __init__(self, host='localhost', port=5672, username='guest', self.extra_fields = extra_fields self.fqdn = fqdn self.facility = facility + self.addFilter(PikaLogFilter()) def makeSocket(self, **kwargs):