# 重寫 rsi > 來源：https://uqer.io/community/share/560dfd84f9f06c4ca82fb597 ```py import talib as ta import numpy as np import pandas as pd from pandas import DataFrame,Series start = '2014-01-01' # 回測起始時間 end = '2015-01-01' # 回測結束時間 benchmark = 'HS300' # 策略參考標準 universe = set_universe('HS300') # 證券池，支持股票和基金 capital_base = 10000000 # 起始資金 freq = 'd' # 策略類型，'d'表示日間策略使用日線回測 refresh_rate = 1 # 調倉頻率，表示執行handle_data的時間間隔，由于freq = 'd'，時間間隔的單位為交易日 pieces=10 #每個標的最多買1/10 def initaialize(account): pass def handle_data(account): prices=account.get_attribute_history('closePrice',100) for s in universe: cun_price=price[s][-1] cun_amount[s]=account.secpos.get(s,0) RSI=ta.RSI(prices[s],9) buy_flag=RSI[-1]>RSI[-2] and RSI[-1]>30 #計算買入條件 sell_flag = RSI[-1]<RSI[-2] and RSI[-1]<70 #計算賣出條件 amount_max=int((0.1*capital_base)/cun_price) #計算單支倉位上限 amount = min(int(2500000/cun_price),amount_max-cun-amount[s]) #計算下單量 if buy_flag and (cun_amount[s]<amount_max): order(s,amount) elif sell_flag and (cun_amount[s]>0): order_to(s,0) --------------------------------------------------------------------------- ValueError Traceback (most recent call last) <mercury-input-6-72d5ab71705d> in <module>() 61 perf = quartz.perf_parse(bt, quartz_acct) 62 elif QUARTZ_CACHE.get('start', 0) == sim_params.first_trading_day and QUARTZ_CACHE.get('end', 0) == sim_params.last_trading_day and QUARTZ_CACHE.get('benchmark', 0) == benchmark and QUARTZ_CACHE.get('universe', 0) == sim_params.universe: ---> 63 strategy = quartz.sim_condition.strategy.TradingStrategy(initialize, handle_data) 64 bt, quartz_acct = quartz.quick_backtest_generator(sim_params = QUARTZ_CACHE['sim_params'], 65 strategy = strategy, python2.7/site-packages/quartz/sim_condition/strategy.pyc in __init__(self, initialize, handle_data) 19 def __init__(self, initialize=None, handle_data=None): 20 if not hasattr(initialize, '__call__'): ---> 21 raise ValueError('initialize must be a function!') 22 else: 23 self._initialize = initialize ValueError: initialize must be a function! ```