Change-Id: I487632435ae575c2507e58ee5682aa03934391b8
Signed-off-by: Pawel Tomaszewski <pawelx.tomaszewski@intel.com>
Signed-off-by: Kamil Wiatrowski <kamilx.wiatrowski@intel.com>
(cherry picked from commit
96015a4a509dc7feb622f97325e8eb39896cc5e3)
# Volodymyr Mytnyk <volodymyrx.mytnyk@intel.com>
#
-from . import yaml
+import yaml
import logging
import datetime
import time
# 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):
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"""