Subversion Repositories SmartDukaan

#!/usr/bin/python
# coding: ascii
from elixir import *
from shop2020.model.v1.catalog.impl import DataService
from shop2020.model.v1.catalog.impl.DataService import Amazonlisted
from shop2020.model.v1.catalog.script import AmazonAsyncScraper
from shop2020.config.client.ConfigClient import ConfigClient

config_client = ConfigClient()
host = config_client.get_property('staging_hostname')

amScraper = AmazonAsyncScraper.Products("AKIAII3SGRXBJDPCHSGQ", "B92xTbNBTYygbGs98w01nFQUhbec1pNCkCsKVfpg", "AF6E3O0VE0X4D")
marketplaceid = "A21TJRUUN4KGV"
DataService.initialize(db_hostname=host)

def run():
    exceptionList = []
    amazonItems = session.query(Amazonlisted).all()
    for amazonItem in amazonItems:
        skus = []
        skus.append(str(amazonItem.itemId))
        try:
            productAttr = amScraper.get_product_attributes_for_sku(marketplaceid, skus)
            print "productAttr ",productAttr
            if productAttr is None:
                raise
        except:
            exceptionList.append(amazonItem.itemId)
            continue
        amazonItem.packagingHeight = productAttr.get('height')
        amazonItem.packagingLength = productAttr.get('length')
        amazonItem.packagingWidth = productAttr.get('width')
        amazonItem.packagingWeight = productAttr.get('weight')
        session.commit()
        
    for itemId in exceptionList:
        print itemId
        
        
    

def main():
    try:
        run()
    finally:
        session.close()

if __name__=='__main__':
    main()