Change-Id: I487632435ae575c2507e58ee5682aa03934391b8
Signed-off-by: Pawel Tomaszewski <pawelx.tomaszewski@intel.com>
Signed-off-by: Kamil Wiatrowski <kamilx.wiatrowski@intel.com>
# Volodymyr Mytnyk <volodymyrx.mytnyk@intel.com>
#
# Volodymyr Mytnyk <volodymyrx.mytnyk@intel.com>
#
import logging
import datetime
import time
import logging
import datetime
import time
# import YAML loader
try:
# import YAML loader
try:
- from .yaml import CLoader as Loader
+ from yaml import CLoader as Loader
- from .yaml import Loader
+ from yaml import Loader
# import synchronized queue
# import synchronized queue
+try:
+ import queue
+except ImportError:
+ import Queue as queue
import json
import sys
import base64
import json
import sys
import base64
import logging
import argparse
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
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"""
class VESApp(Normalizer):
"""VES Application"""