blob: 4e8c99f03b0be87f957644aec7d457f76fd7febf (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
|
from bowdst import get_dir, download_messages
from csv import DictReader
from citco_ops.bowdst import BowdstWire
import datetime
def load_wire_report(workdate: datetime.date):
p = get_dir(workdate) / f"BowdstWires_{workdate:%d %b %Y}.csv"
with open(p) as fh:
reader = DictReader(fh)
for line in reader:
BowdstWire.from_nexen_line(line).stage()
BowdstWire.commit()
if __name__ == "__main__":
import argparse
from serenitas.utils.exchange import ExchangeMessage
parser = argparse.ArgumentParser()
parser.add_argument(
"workdate",
nargs="?",
type=datetime.date.fromisoformat,
default=datetime.date.today(),
help="working date",
)
args = parser.parse_args()
em = ExchangeMessage()
download_messages(em)
load_wire_report(args.workdate)
|
