aboutsummaryrefslogtreecommitdiffstats
path: root/3rd_party/collectd-ves-app
diff options
context:
space:
mode:
Diffstat (limited to '3rd_party/collectd-ves-app')
-rw-r--r--3rd_party/collectd-ves-app/ves_app/normalizer.py11
-rw-r--r--3rd_party/collectd-ves-app/ves_app/ves_app.py13
2 files changed, 18 insertions, 6 deletions
diff --git a/3rd_party/collectd-ves-app/ves_app/normalizer.py b/3rd_party/collectd-ves-app/ves_app/normalizer.py
index 0e92d1a5..95feead1 100644
--- a/3rd_party/collectd-ves-app/ves_app/normalizer.py
+++ b/3rd_party/collectd-ves-app/ves_app/normalizer.py
@@ -17,7 +17,7 @@
# Volodymyr Mytnyk <volodymyrx.mytnyk@intel.com>
#
-from . import yaml
+import yaml
import logging
import datetime
import time
@@ -28,12 +28,15 @@ import re
# import YAML loader
try:
- from .yaml import CLoader as Loader
+ from yaml import CLoader as Loader
except ImportError:
- from .yaml import Loader
+ from yaml import Loader
# import synchronized queue
-import queue
+try:
+ import queue
+except ImportError:
+ import Queue as queue
class Config(object):
diff --git a/3rd_party/collectd-ves-app/ves_app/ves_app.py b/3rd_party/collectd-ves-app/ves_app/ves_app.py
index fa4e9349..a8551239 100644
--- a/3rd_party/collectd-ves-app/ves_app/ves_app.py
+++ b/3rd_party/collectd-ves-app/ves_app/ves_app.py
@@ -15,17 +15,26 @@
import json
import sys
import base64
-import configparser
import logging
import argparse
+try:
+ import configparser
+except ImportError:
+ import ConfigParser as configparser
+
from distutils.util import strtobool
from kafka import KafkaConsumer
from .normalizer import Normalizer
from .normalizer import CollectdValue
-import urllib.request as url
+try:
+ # For Python 3.0 and later
+ import urllib.request as url
+except ImportError:
+ # Fall back to Python 2's urllib2
+ import urllib2 as url
class VESApp(Normalizer):
"""VES Application"""