Subversion Repositories SmartDukaan

Rev

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

Rev 16474 Rev 16561
Line 10... Line 10...
10 
from dtr.dao import Order, SubOrder, AmazonAffiliateInfo
 10 
from dtr.dao import Order, SubOrder, AmazonAffiliateInfo
11 
from dtr.main import getStore, Store as MStore, ParseException, getBrowserObject, \
 11 
from dtr.main import getStore, Store as MStore, ParseException, getBrowserObject, \
12 
    ungzipResponse, tprint
 12 
    ungzipResponse, tprint
13 
from dtr.sources.flipkart import todict, AFF_REPORT_URL
 13 
from dtr.sources.flipkart import todict, AFF_REPORT_URL
14 
from dtr.utils.utils import fetchResponseUsingProxy
 14 
from dtr.utils.utils import fetchResponseUsingProxy
15 
from paramiko import sftp
 - 
 
16 
from paramiko.client import SSHClient
 - 
 
17 
from paramiko.sftp_client import SFTPClient
 - 
 
18 
import base64
 15 
import base64
19 
import gzip
 16 
import gzip
20 
import mechanize
 17 
import mechanize
21 
import os.path
 18 
import os.path
22 
import paramiko
 - 
 
23 
import re
 19 
import re
24 
import time
 20 
import time
25 
import traceback
 21 
import traceback
26 
import urllib2
 22 
import urllib2
27 
from dtr.storage.Mongo import getDealRank
 23 
from dtr.storage.Mongo import getDealRank
Line 675... Line 671...
675 
            session.commit()
 671 
            session.commit()
676
672
677 
    finally:
 673 
    finally:
678 
        session.close()
 674 
        session.close()
679
675
680 
def readSSh(fileName):
 - 
 
681 
    try:
 - 
 
682 
        str1 = open(fileName).read()
 - 
 
683 
        return str1
 - 
 
684 
    except:
 - 
 
685 
        ssh_client = SSHClient()
 - 
 
686 
        str1 = ""
 - 
 
687 
        ssh_client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
 - 
 
688 
        ssh_client.connect('dtr', 22, 'root', 'ecip$dtrMay2014')
 - 
 
689 
        sftp_client = ssh_client.open_sftp()
 - 
 
690 
        try:
 - 
 
691 
            if not os.path.exists(os.path.dirname(fileName)):
 - 
 
692 
                os.makedirs(os.path.dirname(fileName))
 - 
 
693 
            sftp_client.get(fileName, fileName)
 - 
 
694 
            try:
 - 
 
695 
                str1 = open(fileName).read()
 - 
 
696 
                return str1
 - 
 
697 
            finally:
 - 
 
698 
                pass
 - 
 
699 
        except:
 - 
 
700 
            "could not read"
 - 
 
701 
        return str1
 - 
 
702 
 
 - 
 
703 
 
 - 
 
704 
if __name__ == '__main__':
 676 
if __name__ == '__main__':
705 
        main()
 677 
        main()
706 

            678