diff options
Diffstat (limited to 'python/position_file_bowdst.py')
| -rw-r--r-- | python/position_file_bowdst.py | 14 |
1 files changed, 9 insertions, 5 deletions
diff --git a/python/position_file_bowdst.py b/python/position_file_bowdst.py index a34c300c..715aff7a 100644 --- a/python/position_file_bowdst.py +++ b/python/position_file_bowdst.py @@ -12,7 +12,9 @@ def process_upload(trades, asset_type): csvwriter.writerow(HEADERS[asset_type]) csvwriter.writerows(build_line(trade, asset_type) for trade in trades) buf = buf.getvalue().encode() - dest = Path(f"/home/serenitas/flint/{asset_type}.csv") + dest = Path( + f"/home/serenitas/flint/HEDGEMARK.POSITION.BOS_PAT_BOWDOIN.20211116.095655.{asset_type.upper()}Deal.csv" + ) dest.write_bytes(buf) @@ -22,7 +24,7 @@ def build_line(obj, asset_type): # variables -date = datetime.date(2021, 11, 9) +date = datetime.date(2021, 10, 29) dawndb = dbconn("dawndb") @@ -105,7 +107,7 @@ with dawndb.cursor() as c: rename_keys( obj, { - "identifier": "CUSIP", + "cusip": "CUSIP", "description": "SecurityDescription", "notional": "Position", "price": "MarketPrice", @@ -117,9 +119,11 @@ with dawndb.cursor() as c: obj["Fx Rate"] = obj["Local Market Value"] / obj["Base Market Value"] except ZeroDivisionError: obj["Fx Rate"] = 1 - obj["AccountNumber"] = "TELHEEACPB" - obj["Prime Broker"] = "TEST" + obj["AccountNumber"] = "319478" + obj["Prime Broker"] = "BONY" obj["COB Date"] = date + obj["Currency"] = "USD" + obj["SecurityType"] = "Bond" trades.append(obj) process_upload(trades, "bond") |