Subversion Repositories SmartDukaan

Rev

Rev 16416 | Rev 16418 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 16416 Rev 16417
Line 7... Line 7...
7 
from multiprocessing import cpu_count
 7 
from multiprocessing import cpu_count
8 
import optparse
 8 
import optparse
9 
from dtr.storage.MemCache import MemCache
 9 
from dtr.storage.MemCache import MemCache
10 
from dtr.utils.utils import getCashBack
 10 
from dtr.utils.utils import getCashBack
11 
import traceback
 11 
import traceback
12 
from dtr.storage import Mongo
 - 
 
13 
from dtr.CouponMaster import addToPaytmMaster
 12 
from dtr.CouponMaster import addToPaytmMaster
- 
 
 13 
from dtr.storage import DataService
14 
 
 14 
 
15 
con = None
 15 
con = None
16 
 
 16 
 
17 
parser = optparse.OptionParser()
 17 
parser = optparse.OptionParser()
18 
parser.add_option("-m", "--m", dest="mongoHost",
 18 
parser.add_option("-m", "--m", dest="mongoHost",
Line 22... Line 22...
22 
 
 22 
 
23 
(options, args) = parser.parse_args()
 23 
(options, args) = parser.parse_args()
24 
 
 24 
 
25 
mc = MemCache(options.mongoHost)
 25 
mc = MemCache(options.mongoHost)
26 
 
 26 
 
- 
 
 27 
DataService.initialize(db_hostname=options.mongoHost)
- 
 
 28 
 
27 
ignoreItems = []
 29 
ignoreItems = []
28 
SOURCE_MAP = {'AMAZON':1,'FLIPKART':2,'SNAPDEAL':3,'SAHOLIC':4, 'SHOPCLUES.COM':5,'PAYTM.COM':6}
 30 
SOURCE_MAP = {'AMAZON':1,'FLIPKART':2,'SNAPDEAL':3,'SAHOLIC':4, 'SHOPCLUES.COM':5,'PAYTM.COM':6}
29 
 
 31 
 
30 
def get_mongo_connection(host=options.mongoHost, port=27017):
 32 
def get_mongo_connection(host=options.mongoHost, port=27017):
31 
    global con
 33 
    global con