31 lines
1020 B
Python
31 lines
1020 B
Python
# encoding: UTF-8
|
||
|
||
"""
|
||
定时服务，可无人值守运行，实现每日自动下载更新历史行情数据到数据库中。
|
||
"""
|
||
from __future__ import print_function
|
||
|
||
from dataService import *
|
||
|
||
|
||
if __name__ == '__main__':
|
||
taskCompletedDate = None
|
||
|
||
# 生成一个随机的任务下载时间，用于避免所有用户在同一时间访问数据服务器
|
||
taskTime = datetime.time(hour=17, minute=random.randint(1,59))
|
||
|
||
# 进入主循环
|
||
while True:
|
||
t = datetime.datetime.now()
|
||
|
||
# 每天到达任务下载时间后，执行数据下载的操作
|
||
if t.time() > taskTime and (taskCompletedDate is None or t.date() != taskCompletedDate):
|
||
# 下载1000根分钟线数据，足以覆盖过去两天的行情
|
||
downloadAllMinuteBar(1000)
|
||
|
||
# 更新任务完成的日期
|
||
taskCompletedDate = t.date()
|
||
else:
|
||
print(u'当前时间%s，任务定时%s' %(t, taskTime))
|
||
|
||
time.sleep(60) |