From 152d3f49f8208adc1d0b37d41356163ca65fe0ca Mon Sep 17 00:00:00 2001 From: Kerim Gokarslan Date: Tue, 17 Oct 2017 15:17:44 -0700 Subject: NFVBENCH-42 Add multiple fluentd aggregators support Change-Id: I5b752f9ad4f7b4a60f2678d22467db570e02ab82 Signed-off-by: Kerim Gokarslan --- test/test_nfvbench.py | 35 ++++++++++++++++++++++++++++++++++- 1 file changed, 34 insertions(+), 1 deletion(-) (limited to 'test') diff --git a/test/test_nfvbench.py b/test/test_nfvbench.py index 85342bb..2578407 100644 --- a/test/test_nfvbench.py +++ b/test/test_nfvbench.py @@ -786,11 +786,44 @@ def test_config(): def test_fluentd(): logger = logging.getLogger('fluent-logger') - handler = FluentLogHandler('nfvbench', fluentd_port=7081) + + class FluentdConfig(dict): + def __getattr__(self, attr): + return self.get(attr) + + fluentd_configs = [ + FluentdConfig({ + 'logging_tag': 'nfvbench', + 'result_tag': 'resultnfvbench', + 'ip': '127.0.0.1', + 'port': 7081 + }), + FluentdConfig({ + 'logging_tag': 'nfvbench', + 'result_tag': 'resultnfvbench', + 'ip': '127.0.0.1', + 'port': 24224 + }), + FluentdConfig({ + 'logging_tag': None, + 'result_tag': 'resultnfvbench', + 'ip': '127.0.0.1', + 'port': 7082 + }), + FluentdConfig({ + 'logging_tag': 'nfvbench', + 'result_tag': None, + 'ip': '127.0.0.1', + 'port': 7083 + }) + ] + + handler = FluentLogHandler(fluentd_configs=fluentd_configs) logger.addHandler(handler) logger.setLevel(logging.INFO) logger.info('test') logger.warning('test %d', 100) + try: raise Exception("test") except Exception: -- cgit 1.2.3-korg