blob: 3db5a6d7ab846998eb5e77c6ff318fbb8208bd5d (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
import redis
from pickle import dumps
import datetime
import os
import time
from common import root
def run():
dealsfile = os.path.join(root, "scripts", "deals_to_price.txt")
q = redis.Redis(unix_socket_path='/var/run/redis/redis.sock')
while True:
workdate = str(datetime.date.today())
if os.path.exists(dealsfile):
with open(dealsfile) as fh:
for line in fh:
dealname, reinvflag = line.rstrip().split("\t")
q.rpush("tasks", dumps(("build_portfolio", [workdate, dealname, reinvflag]), protocol=2))
os.unlink(dealsfile)
time.sleep(3)
if __name__=="__main__":
run()
|
