diff --git a/README.rst b/README.rst index ee1c8fd..e293054 100644 --- a/README.rst +++ b/README.rst @@ -47,6 +47,9 @@ wiki文档_ * Anaconda用户可以用 >>> conda install -c quantopian ta-lib +* finance依赖 + * 安装 https://github.com/matplotlib/mpl_finance + 策略组合DEMO ----------- diff --git a/demo/plot_strategy.py b/demo/plot_strategy.py index f373311..1d50a46 100644 --- a/demo/plot_strategy.py +++ b/demo/plot_strategy.py @@ -1,12 +1,5 @@ # -*- coding: utf-8 -*- -# @file plot_strategy.py -# @brief 策略运行和图表展示 -# @author wondereamer -# @version 0.2 -# @date 2015-12-09 - -import six from quantdigger import ( Strategy, MA, diff --git a/quantdigger/technicals/common.py b/quantdigger/technicals/common.py index fab7e08..efd301d 100644 --- a/quantdigger/technicals/common.py +++ b/quantdigger/technicals/common.py @@ -171,7 +171,7 @@ def __init__(self, open, close, volume, name='volume', self.values = ndarray(volume) def plot(self, widget): - import matplotlib.finance as finance + import mpl_finance as finance self.widget = widget finance.volume_overlay(widget, self.open, self.close, self.volume, self.colorup, self.colordown, self.width) diff --git a/tests/test_rabbitmq_speed.py b/tests/test_rabbitmq_speed.py new file mode 100644 index 0000000..fa29031 --- /dev/null +++ b/tests/test_rabbitmq_speed.py @@ -0,0 +1,14 @@ +#!/usr/bin/env python +# encoding: utf-8 + + +from timeit import timeit + +from nameko.standalone.rpc import ClusterRpcProxy +with ClusterRpcProxy({"AMQP_URI": "pyamqp://guest:guest@localhost"}) as rpc: + + def func(): + result = rpc.backend_service.say_hello("world") + + t = timeit('func()', 'from __main__ import func', number=100) + print(t) diff --git a/tests/test_rpc.py b/tests/test_rpc.py deleted file mode 100644 index 5ff3327..0000000 --- a/tests/test_rpc.py +++ /dev/null @@ -1,7 +0,0 @@ -from quantdigger.event.eventengine import ZMQEventEngine -from rpc import EventRPCClient - -engine = ZMQEventEngine('TestWindowGate') -engine.start() -client = EventRPCClient('client', engine, 'test') -client.sync_call('print_hello', { 'data': 'nihao' }) diff --git a/tests/test_zmq_speed.py b/tests/test_zmq_speed.py index b422756..1e9e6ed 100644 --- a/tests/test_zmq_speed.py +++ b/tests/test_zmq_speed.py @@ -36,7 +36,7 @@ def func(): return -t = timeit('func()', 'from __main__ import func', number=1000) +t = timeit('func()', 'from __main__ import func', number=100) print(t) subprocess.Popen.kill(backend)