blob: c45c1cf27eb9eca4578c40fac3323b4783893df5 (
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
|
import redis
from pickle import dumps
import datetime
import os
import time
from common import root
import daemon
from daemon.pidlockfile import TimeoutPIDLockFile
def run():
dealsfile = os.path.join(root, "scripts", "deals_to_price.txt")
q = redis.Redis(unix_socket_path='/var/run/redis/redis.sock')
workdate = str(datetime.date.today())
while True:
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__":
with daemon.DaemonContext(pidfile = TimeoutPIDLockFile('/var/run/master.pid',10)):
run()
|
