python使用用Wind接口获取全部A股历史交易数据

1、Python任务调度之sched 这次我们主要讲解下Python自带模块当中的sched，不但小巧，也很强大，在实际应用中，某些场合还是可以用到的。作为一名Linux的SA，我们已经习惯了用crontab，而sched提供了一种延迟处理机制，也可以理解为任务调度的另一种方式的实现。 scheduler.enter(delay, priority, action, argument) delay：延迟时间 priority：优先级 action：回调函数 argument：回调函数的参数 我们来写一个非常简单的例子：import sched import time scheduler = sch

2、ed.scheduler(time.time, time.sleep) def func(name): print action: %s % name , time.time() print START:, time.time() scheduler.enter(2, 1, func, (fight,) scheduler.enter(3, 1, func, (make peace,) scheduler.run() print END:, time.time() 运行结果如下： START:.4 action:fight .4 action: makepeace .4 END:.4 我们再举

3、一个简单的例子说明下sched的其它特性：import sched import time scheduler = sched.scheduler(time.time, time.sleep) def func(name): print BEGIN: %s: % name, time.time() time.sleep(2) print FINISH %s: % name, time.time() print START:, time.time() scheduler.enter(2, 1, func, (fight,) scheduler.enter(3, 1, func, (make pe

4、ace,) scheduler.run() print END:, time.time() 运行结果如下： START:.12 BEGIN:fight: .12 FINISHfight: .12 BEGIN: makepeace: .12 FINISH makepeace: .12 END:.12 我们仔细观察下两次任务调度的时间间隔，发现是同时运行的？那又是为什么呢？run()一直被阻塞，直到所有事件被全部执行完.每个事件在同一线程中运行，所以如果一个事件的执行时间大于其他事件的延迟时间，那么，就会产生重叠。重叠的解决方法是推迟后来事件的执行时间。这样保证没有丢失任何事件，但这些事件的调用时

5、刻会比原先设定的迟。 上面的例子第二个事件在第一个事件运行结束后立即运行，因为第一个事件的执行时间足够长，已经超过第二个事件的预期开始时刻。（本来应该秒运行） 我们再介绍另外一个保证action在同一时刻执行的函数： scheduler.enterabs(time, priority, action, argument)import sched import time scheduler = sched.scheduler(time.time, time.sleep) now = time.time() def func(name): print action:, time.time(), n

6、ame print START:, now scheduler.enterabs(now + 2, 2, func, (make peace,) scheduler.enterabs(now + 2, 1, func, (fight,) scheduler.run() print END:, now 运行结果如下： START:.38 action:.38 fight action:.38 make peace END:.38 因为优先级的关系，所以先fight，然后再makepeace，打架是如此重要.总体来讲，如果想单纯的替换crontab的话，Scheduler框架更加适合，做延迟任务的

7、调度处理的话sched还是可以考虑的。 如果我们想要取消任务调度，可以使用cancel()函数。在上面的例子中出现了阻塞延迟的现象，如果引用线程机制就会避免这种情况的发生，我们简单举个例子：import sched import threading import time scheduler = sched.scheduler(time.time, time.sleep) counter = 0 def increment_counter(name): global counter print action: %s % name , time.time() counter += 1 print

8、 counter: , counter print START:, time.time() action1 = scheduler.enter(2, 1, increment_counter, (action1,) action2 = scheduler.enter(3, 1, increment_counter, (action2,) t = threading.Thread(target=scheduler.run) t.start() scheduler.cancel(action1) t.join() print counter:, counter print END:, time.time() 运行结果如下： START:.27 action:action2.27 counter: 1 counter:1 EN