blob: ff3b7574aeb8bf8eb2484861b01227e4b4bf87e8 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
import datetime
from env import DAILY_DIR
from exchange import ExchangeMessage
em = ExchangeMessage()
for msg in em.get_msgs(
20, path=["BowdoinOps", "Reports"], subject__startswith="Document(s) from Reporting"
):
if msg.sender == "notify@bnymellon.com":
for attach in msg.attachments:
fname = attach.name
if fname.endswith("csv") and fname.startswith("Asset Detail"):
date = datetime.datetime.strptime(
fname.split("_")[1].split(".")[0], "%d %b %Y"
).date()
p = DAILY_DIR / str(date) / "Reports" / fname
if not p.parent.exists():
p.parent.mkdir(parents=True)
p.write_bytes(attach.content)
|
