diff options
Diffstat (limited to 'python/markit/loans.py')
| -rw-r--r-- | python/markit/loans.py | 13 |
1 files changed, 8 insertions, 5 deletions
diff --git a/python/markit/loans.py b/python/markit/loans.py index b6ec11d8..f4c22818 100644 --- a/python/markit/loans.py +++ b/python/markit/loans.py @@ -9,9 +9,10 @@ from psycopg2 import IntegrityError logger = logging.getLogger(__name__)
def download_facility(workdate, payload):
- r = requests.get('https://loans.markit.com/loanx/LoanXFacilityUpdates.csv', params=payload)
+ r = requests.post('https://loans.markit.com/loanx/LoanXFacilityUpdates.csv',
+ params=payload)
facility_filename = os.path.join(os.environ['DATA_DIR'], "Facility files", "facility_{0}.csv".format(workdate))
- with open( facility_filename, "wb") as fh:
+ with open(facility_filename, "wb") as fh:
fh.write(r.content)
@with_connection('etdb')
@@ -37,11 +38,12 @@ def insert_facility(conn, workdate): @with_connection('etdb')
def download_marks(conn, workdate, payload):
- r = requests.get('https://loans.markit.com/loanx/LoanXMarks.csv', params=payload)
+ r = requests.post('https://loans.markit.com/loanx/LoanXMarks.csv',
+ params=payload)
marks_filename = os.path.join(os.environ['DATA_DIR'], "markit", "markit_data_{0}.csv".format(workdate))
with open(marks_filename, "wb") as fh:
fh.write(r.content)
- sqlstring = "INSERT INTO markit_prices VALUES( {0} )".format( ",".join([ "%s" ] * 5))
+ sqlstring = "INSERT INTO markit_prices VALUES( {0} )".format(",".join([ "%s" ] * 5))
with open(marks_filename, "r") as fh:
reader = csv.DictReader(fh)
if 'Authentication failed' in reader.fieldnames[0]:
@@ -67,7 +69,8 @@ def update_facility(conn, workdate, payload): c.execute(sqlstring)
for loanxid in c:
payload.update({'LOANXID': loanxid[0]})
- r = requests.get('https://loans.markit.com/loanx/LoanXOneFacility.csv', params=payload)
+ r = requests.post('https://loans.markit.com/loanx/LoanXOneFacility.csv',
+ params=payload)
header, *rest = r.content.decode().split('\n')
if flag:
fh.write(rest[0] + "\n")
|