aboutsummaryrefslogtreecommitdiffstats
path: root/python/markit
diff options
context:
space:
mode:
Diffstat (limited to 'python/markit')
-rw-r--r--python/markit/loans.py16
1 files changed, 8 insertions, 8 deletions
diff --git a/python/markit/loans.py b/python/markit/loans.py
index f4f13d4e..feece0c7 100644
--- a/python/markit/loans.py
+++ b/python/markit/loans.py
@@ -8,20 +8,19 @@ from . import DATA_DIR
logger = logging.getLogger(__name__)
+BASE_URL = "https://loans.markit.com/loanx"
+
def download_facility(workdate, payload):
facility_filename = DATA_DIR / "Facility files" / f"facility_{workdate}.csv"
- r = requests.post(
- "https://loans.markit.com/loanx/LoanXFacilityUpdates.csv", params=payload
- )
+ r = requests.post(f"{BASE_URL}/LoanXFacilityUpdates.csv", params=payload)
+ breakpoint()
with facility_filename.open("wb") as fh:
fh.write(r.content)
def download_recupdates(workdate, payload):
- r = requests.post(
- "https://loans.markit.com/loanx/LoanXRecUpdates.csv", params=payload
- )
+ r = requests.post(f"{BASE_URL}/LoanXRecUpdates.csv", params=payload)
facility_rec_update = DATA_DIR / "Facility files" / f"facility_rec_{workdate}.csv"
with facility_rec_update.open("wb") as fh:
fh.write(r.content)
@@ -53,8 +52,9 @@ def insert_facility(conn, workdate):
@with_connection("etdb")
def download_marks(conn, workdate, payload):
- r = requests.post("https://loans.markit.com/loanx/LoanXMarks.csv", params=payload)
+ r = requests.post(f"{BASE_URL}/LoanXMarks.csv", params=payload)
marks_filename = DATA_DIR / "markit" / f"markit_data_{workdate}.csv"
+ breakpoint()
with marks_filename.open("wb") as fh:
fh.write(r.content)
sqlstring = "INSERT INTO markit_prices VALUES( {0} )".format(",".join(["%s"] * 5))
@@ -96,7 +96,7 @@ def update_facility(conn, workdate, payload):
for loanxid in c:
payload.update({"LOANXID": loanxid[0]})
r = requests.post(
- "https://loans.markit.com/loanx/LoanXOneFacility.csv",
+ f"{BASE_URL}/LoanXOneFacility.csv",
params=payload,
)
header, *rest = r.content.decode().split("\n")