diff options
Diffstat (limited to 'python/upload_bbh_trades.py')
| -rw-r--r-- | python/upload_bbh_trades.py | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/python/upload_bbh_trades.py b/python/upload_bbh_trades.py index bbfea5eb..03802f42 100644 --- a/python/upload_bbh_trades.py +++ b/python/upload_bbh_trades.py @@ -7,6 +7,7 @@ import pandas as pd from sqlalchemy.exc import IntegrityError from io import StringIO from serenitas.utils.env import DAILY_DIR +from serenitas.utils.remote import SftpClient if __name__ == "__main__": conn = dbconn("dawndb") @@ -63,9 +64,8 @@ if __name__ == "__main__": [obj.get(header, None) for header in BBH_BOND_HEADERS] ) buf = buf.getvalue().encode() - dest = ( - DAILY_DIR - / str(datetime.date.today()) - / f'LMCG_BBH_TRADES_P.{obj["Client Reference Number"].replace("_", "")}.csv' - ) + fname = 'LMCG_BBH_TRADES_P.{obj["Client Reference Number"].replace("_", "")}.csv' + dest = DAILY_DIR / str(datetime.date.today()) / fname + sftp = SftpClient.from_creds("bbh") + sftp.put(buf, fname) dest.write_bytes(buf) |