"""中性化函数 将序列与 how 中输入的相关变量做回归取残差，去除序列与相关变量的相关性 输入: data: pd.Series 待中性化的序列，序列的 index 为股票的 code how: str list 相关变量的名称，默认为 ['jq_l1', 'market_cap'] 输入格式参照 Factor 中的 dependencies 属性 (https://www.joinquant.com/help/api/help?name=factor) date: 日期格式 str 将用 date 这天的相关变量数据对 data 进行中性化 axis: 0 或 1 如果 data 为 pd.DataFrame，沿哪个方向做标准化，默认为 1 0 为对每列做中性化，1 为对每行做中性化 输出: pd.Series，中性化后的序列 说明: 1. 为了方便输入，行业数据可以直接用对应的行业类别代码获取。 如输入 how=['jq_l1'] 和 how=['HY001','HY002','HY003','HY004','HY005','HY006','HY007','HY008','HY009','HY010','HY011'] 是等价的 具体为 证监会行业: 'zjw' 聚宽一级: 'jq_l1' 聚宽二级: 'jq_l2' 申万一级: 'sw_l1' 申万二级: 'sw_l2' 申万三级: 'sw_l3' （参考 https://www.joinquant.com/api#jqdatagetindustries-获取行业列表） 2. how 中还可以输入 barra 风格因子的名称 ['size', 'beta', 'momentum', 'residual_volatility', 'non_linear_size', 'book_to_price_ratio', 'liquidity', 'earnings_yield', 'growth', 'leverage'] 举例: neutralize(pd.Series(np.random.rand(300), index=get_index_stocks('000300.XSHG', date='2018-05-02')), how=['jq_l1', 'market_cap'], date='2018-05-02') 可以百度'中性化'获取更多资料! 文档中是有一处失误,谢谢提醒!

1. 是对行业和市值进行中性化； 2. 是'jq_l2'：聚宽二级行业； 3. barra如就是how中的参数，格式排版有些问题，已修正。

@薛定谔の喵 请问下，可不可以分开来只对行业中性化或者只对市值中性化呢

@Terrywu 可以的,api只是一个示例,您试试看

@薛定谔の喵 how: str list 相关变量的名称，默认为 ['jq_l1', 'market_cap'] 这里面的参数改成['jq_l1']，就是对聚宽一级行业进行行业中性化是吗

@Terrywu 是对因子值根据聚宽一级行业进行中性化

@薛定谔の喵 Thx~

@薛定谔の喵 用聚宽1级进行行业和市值中性化，完全没问题，但是用聚宽2级就出现错误，能帮忙看一下吗 Traceback (most recent call last): File "jqboson/core/entry.py", line 373, in _run engine.start() File "jqboson/core/engine.py", line 240, in start self._dispatcher.start() File "jqboson/core/dispatcher.py", line 209, in start self._loop() File "jqboson/core/dispatcher.py", line 189, in _loop self._event_bus.emit(ev[1]) File "jqboson/core/bus.py", line 35, in emit ret.append(call(event)) File "jqboson/core/strategy.py", line 251, in _wrapper return cb(self._context.strategy_environment.strategy_context) File "/tmp/strategy/user_code.py", line 64, in fun_main fdf = get_factors(g.feasible_stocks, context, g.factors,startdate) File "/tmp/strategy/user_code.py", line 379, in get_factors aa = globals()[tmp](stocks_list,context,fdate)#,value) File "/tmp/strategy/user_code.py", line 448, in get_df_BP df_BP=neutralize(df_BP, how=['jq_l2', 'market_cap'], date=fdate, axis=0) File "jqfactor/__init__.py", line 295, in neutralize return neutralize(data, how=how, date=date, axis=axis) File "jqfactor/preprocess.py", line 229, in neutralize classified_fields=filter_factors([factor]), File "jqfactor/calculate.py", line 488, in _get_basic_factor_data industry_data = self._get_industry_data(securities, dates, industries) File "jqfactor/calculate.py", line 303, in _get_industry_data sec_codes = self.idst_store.get_security_industry_date(securities, industries) File "jqdata/stores/industry_store.py", line 162, in get_security_industry_date IndustryEntity.stock.in_(stock_list)).filter(IndustryEntity.code.in_(industries)).distinct().all() File "sqlalchemy/orm/query.py", line 2399, in all return list(self) File "sqlalchemy/orm/query.py", line 2516, in __iter__ return self._execute_and_instances(context) File "sqlalchemy/orm/query.py", line 2531, in _execute_and_instances result = conn.execute(querycontext.statement, self._params) File "sqlalchemy/engine/base.py", line 914, in execute return meth(self, multiparams, params) File "sqlalchemy/sql/elements.py", line 323, in _execute_on_connection return connection._execute_clauseelement(self, multiparams, params) File "sqlalchemy/engine/base.py", line 1010, in _execute_clauseelement compiled_sql, distilled_params File "sqlalchemy/engine/base.py", line 1146, in _execute_context context) File "sqlalchemy/engine/base.py", line 1341, in _handle_dbapi_exception exc_info File "sqlalchemy/util/compat.py", line 199, in raise_from_cause reraise(type(exception), exception, tb=exc_tb) File "sqlalchemy/engine/base.py", line 1139, in _execute_context context) File "sqlalchemy/engine/default.py", line 450, in do_execute cursor.execute(statement, parameters) OperationalError: (sqlite3.OperationalError) too many SQL variables [SQL: u'SELECT DISTINCT industry.stock AS industry_stock, industry.code AS industry_code, industry.stock_startdate AS industry_stock_startdate, industry.stock_enddate AS industry_stock_enddate \nFROM industry \nWHERE industry.stock IN (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) AND industry.code IN (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)'] [parameters: ('600000.XSHG', '600004.XSHG', '600006.XSHG', '600007.XSHG', '600008.XSHG', '600009.XSHG', '600010.XSHG', '600011.XSHG', '600012.XSHG', '600015.XSHG', '600016.XSHG', '600017.XSHG', '600018.XSHG', '600019.XSHG', '600021.XSHG', '600022.XSHG', '600026.XSHG', '600027.XSHG', '600028.XSHG', '600029.XSHG', '600030.XSHG', '600031.XSHG', '600033.XSHG', '600035.XSHG', '600036.XSHG', '600037.XSHG', '600038.XSHG', '600039.XSHG', '600048.XSHG', '600050.XSHG', '600051.XSHG', '600052.XSHG', '600053.XSHG', '600054.XSHG', '600055.XSHG', '600056.XSHG', '600057.XSHG', '600058.XSHG', '600059.XSHG', '600060.XSHG', '600061.XSHG', '600062.XSHG', '600064.XSHG', '600066.XSHG', '600067.XSHG', '600068.XSHG', '600069.XSHG', '600070.XSHG', '600071.XSHG', '600072.XSHG', '600073.XSHG', '600075.XSHG', '600076.XSHG', '600077.XSHG', '600078.XSHG', '600079.XSHG', '600080.XSHG', '600081.XSHG', '600082.XSHG', '600083.XSHG', '600084.XSHG', '600085.XSHG', '600086.XSHG', '600088.XSHG', '600089.XSHG', '600090.XSHG', '600091.XSHG', '600093.XSHG', '600094.XSHG', '600095.XSHG', '600096.XSHG', '600097.XSHG', '600098.XSHG', '600099.XSHG', '600100.XSHG', '600101.XSHG', '600103.XSHG', '600104.XSHG', '600105.XSHG', '600106.XSHG', '600107.XSHG', '600108.XSHG', '600109.XSHG', '600110.XSHG', '600111.XSHG', '600112.XSHG', '600113.XSHG', '600114.XSHG', '600115.XSHG', '600116.XSHG', '600117.XSHG', '600118.XSHG', '600119.XSHG', '600120.XSHG', '600122.XSHG', '600123.XSHG', '600125.XSHG', '600126.XSHG', '600127.XSHG', '600128.XSHG', '600129.XSHG', '600130.XSHG', '600131.XSHG', '600132.XSHG', '600133.XSHG', '600135.XSHG', '600136.XSHG', '600137.XSHG', '600138.XSHG', '600139.XSHG', '600141.XSHG', '600143.XSHG', '600145.XSHG', '600148.XSHG', '600149.XSHG', '600150.XSHG', '600152.XSHG', '600153.XSHG', '600155.XSHG', '600156.XSHG', '600157.XSHG', '600158.XSHG', '600159.XSHG', '600160.XSHG', '600161.XSHG', '600162.XSHG', '600163.XSHG', '600165.XSHG', '600166.XSHG', '600167.XSHG', '600168.XSHG', '600169.XSHG', '600170.XSHG', '600171.XSHG', '600172.XSHG', '600173.XSHG', '600175.XSHG', '600176.XSHG', '600177.XSHG', '600178.XSHG', '600180.XSHG', '600182.XSHG', '600183.XSHG', '600184.XSHG', '600185.XSHG', '600186.XSHG', '600187.XSHG', '600188.XSHG', '600189.XSHG', '600190.XSHG', '600192.XSHG', '600193.XSHG', '600195.XSHG', '600196.XSHG', '600197.XSHG', '600198.XSHG', '600199.XSHG', '600200.XSHG', '600201.XSHG', '600202.XSHG', '600203.XSHG', '600206.XSHG', '600207.XSHG', '600208.XSHG', '600209.XSHG', '600210.XSHG', '600211.XSHG', '600212.XSHG', '600213.XSHG', '600215.XSHG', '600216.XSHG', '600217.XSHG', '600218.XSHG', '600219.XSHG', '600220.XSHG', '600221.XSHG', '600222.XSHG', '600223.XSHG', '600226.XSHG', '600227.XSHG', '600228.XSHG', '600229.XSHG', '600230.XSHG', '600231.XSHG', '600232.XSHG', '600233.XSHG', '600234.XSHG', '600235.XSHG', '600236.XSHG', '600237.XSHG', '600238.XSHG', '600239.XSHG', '600240.XSHG', '600241.XSHG', '600242.XSHG', '600243.XSHG', '600246.XSHG', '600247.XSHG', '600248.XSHG', '600249.XSHG', '600250.XSHG', '600251.XSHG', '600252.XSHG', '600255.XSHG', '600256.XSHG', '600257.XSHG', '600258.XSHG', '600259.XSHG', '600260.XSHG', '600261.XSHG', '600262.XSHG', '600265.XSHG', '600266.XSHG', '600267.XSHG', '600268.XSHG', '600269.XSHG', '600270.XSHG', '600271.XSHG', '600272.XSHG', '600275.XSHG', '600276.XSHG', '600277.XSHG', '600278.XSHG', '600279.XSHG', '600280.XSHG', '600281.XSHG', '600282.XSHG', '600283.XSHG', '600284.XSHG', '600285.XSHG', '600288.XSHG', '600289.XSHG', '600291.XSHG', '600292.XSHG', '600293.XSHG', '600297.XSHG', '600298.XSHG', '600300.XSHG', '600302.XSHG', '600303.XSHG', '600305.XSHG', '600306.XSHG', '600307.XSHG', '600308.XSHG', '600309.XSHG', '600310.XSHG', '600311.XSHG', '600313.XSHG', '600315.XSHG', '600316.XSHG', '600317.XSHG', '600318.XSHG', '600319.XSHG', '600320.XSHG', '600321.XSHG', '600322.XSHG', '600323.XSHG', '600325.XSHG', '600326.XSHG', '600327.XSHG', '600328.XSHG', '600329.XSHG', '600330.XSHG', '600331.XSHG', '600332.XSHG', '600333.XSHG', '600335.XSHG', '600336.XSHG', '600337.XSHG', '600339.XSHG', '600340.XSHG', '600343.XSHG', '600345.XSHG', '600346.XSHG', '600348.XSHG', '600350.XSHG', '600351.XSHG', '600352.XSHG', '600353.XSHG', '600354.XSHG', '600355.XSHG', '600356.XSHG', '600360.XSHG', '600361.XSHG', '600362.XSHG', '600363.XSHG', '600365.XSHG', '600366.XSHG', '600367.XSHG', '600368.XSHG', '600369.XSHG', '600370.XSHG', '600371.XSHG', '600372.XSHG', '600373.XSHG', '600376.XSHG', '600377.XSHG', '600378.XSHG', '600379.XSHG', '600380.XSHG', '600381.XSHG', '600382.XSHG', '600383.XSHG', '600385.XSHG', '600386.XSHG', '600387.XSHG', '600388.XSHG', '600389.XSHG', '600390.XSHG', '600391.XSHG', '600392.XSHG', '600393.XSHG', '600395.XSHG', '600396.XSHG', '600397.XSHG', '600398.XSHG', '600399.XSHG', '600400.XSHG', '600401.XSHG', '600403.XSHG', '600405.XSHG', '600408.XSHG', '600409.XSHG', '600410.XSHG', '600415.XSHG', '600416.XSHG', '600418.XSHG', '600419.XSHG', '600420.XSHG', '600421.XSHG', '600422.XSHG', '600423.XSHG', '600425.XSHG', '600426.XSHG', '600428.XSHG', '600429.XSHG', '600432.XSHG', '600435.XSHG', '600436.XSHG', '600438.XSHG', '600439.XSHG', '600444.XSHG', '600446.XSHG', '600448.XSHG', '600449.XSHG', '600452.XSHG', '600455.XSHG', '600456.XSHG', '600458.XSHG', '600459.XSHG', '600460.XSHG', '600461.XSHG', '600463.XSHG', '600466.XSHG', '600467.XSHG', '600468.XSHG', '600469.XSHG', '600470.XSHG', '600475.XSHG', '600476.XSHG', '600477.XSHG', '600478.XSHG', '600479.XSHG', '600480.XSHG', '600481.XSHG', '600482.XSHG', '600483.XSHG', '600485.XSHG', '600486.XSHG', '600487.XSHG', '600488.XSHG', '600489.XSHG', '600490.XSHG', '600491.XSHG', '600493.XSHG', '600495.XSHG', '600496.XSHG', '600497.XSHG', '600498.XSHG', '600499.XSHG', '600500.XSHG', '600501.XSHG', '600502.XSHG', '600503.XSHG', '600505.XSHG', '600506.XSHG', '600507.XSHG', '600508.XSHG', '600509.XSHG', '600510.XSHG', '600511.XSHG', '600512.XSHG', '600513.XSHG', '600515.XSHG', '600516.XSHG', '600517.XSHG', '600518.XSHG', '600519.XSHG', '600521.XSHG', '600522.XSHG', '600523.XSHG', '600525.XSHG', '600526.XSHG', '600527.XSHG', '600528.XSHG', '600529.XSHG', '600530.XSHG', '600531.XSHG', '600532.XSHG', '600533.XSHG', '600535.XSHG', '600536.XSHG', '600537.XSHG', '600538.XSHG', '600539.XSHG', '600540.XSHG', '600543.XSHG', '600545.XSHG', '600546.XSHG', '600547.XSHG', '600548.XSHG', '600549.XSHG', '600550.XSHG', '600551.XSHG', '600552.XSHG', '600555.XSHG', '600557.XSHG', '600558.XSHG', '600559.XSHG', '600560.XSHG', '600561.XSHG', '600563.XSHG', '600565.XSHG', '600566.XSHG', '600568.XSHG', '600569.XSHG', '600570.XSHG', '600571.XSHG', '600572.XSHG', '600573.XSHG', '600575.XSHG', '600576.XSHG', '600580.XSHG', '600581.XSHG', '600582.XSHG', '600584.XSHG', '600585.XSHG', '600586.XSHG', '600587.XSHG', '600588.XSHG', '600589.XSHG', '600590.XSHG', '600592.XSHG', '600593.XSHG', '600594.XSHG', '600595.XSHG', '600597.XSHG', '600598.XSHG', '600599.XSHG', '600600.XSHG', '600601.XSHG', '600602.XSHG', '600603.XSHG', '600604.XSHG', '600605.XSHG', '600606.XSHG', '600608.XSHG', '600609.XSHG', '600610.XSHG', '600611.XSHG', '600612.XSHG', '600613.XSHG', '600614.XSHG', '600615.XSHG', '600616.XSHG', '600617.XSHG', '600618.XSHG', '600619.XSHG', '600620.XSHG', '600621.XSHG', '600622.XSHG', '600623.XSHG', '600624.XSHG', '600626.XSHG', '600628.XSHG', '600629.XSHG', '600630.XSHG', '600633.XSHG', '600634.XSHG', '600635.XSHG', '600636.XSHG', '600637.XSHG', '600638.XSHG', '600639.XSHG', '600640.XSHG', '600641.XSHG', '600642.XSHG', '600643.XSHG', '600644.XSHG', '600645.XSHG', '600647.XSHG', '600649.XSHG', '600650.XSHG', '600651.XSHG', '600652.XSHG', '600653.XSHG', '600654.XSHG', '600655.XSHG', '600657.XSHG', '600658.XSHG', '600660.XSHG', '600661.XSHG', '600662.XSHG', '600663.XSHG', '600664.XSHG', '600665.XSHG', '600666.XSHG', '600668.XSHG', '600671.XSHG', '600673.XSHG', '600675.XSHG', '600676.XSHG', '600677.XSHG', '600679.XSHG', '600680.XSHG', '600681.XSHG', '600682.XSHG', '600683.XSHG', '600685.XSHG', '600686.XSHG', '600687.XSHG', '600688.XSHG', '600690.XSHG', '600691.XSHG', '600692.XSHG', '600693.XSHG', '600694.XSHG', '600695.XSHG', '600696.XSHG', '600697.XSHG', '600701.XSHG', '600702.XSHG', '600703.XSHG', '600704.XSHG', '600705.XSHG', '600706.XSHG', '600707.XSHG', '600708.XSHG', '600710.XSHG', '600711.XSHG', '600712.XSHG', '600713.XSHG', '600714.XSHG', '600715.XSHG', '600716.XSHG', '600717.XSHG', '600718.XSHG', '600719.XSHG', '600720.XSHG', '600721.XSHG', '600723.XSHG', '600724.XSHG', '600725.XSHG', '600726.XSHG', '600727.XSHG', '600728.XSHG', '600729.XSHG', '600730.XSHG', '600731.XSHG', '600732.XSHG', '600733.XSHG', '600734.XSHG', '600735.XSHG', '600736.XSHG', '600737.XSHG', '600738.XSHG', '600739.XSHG', '600740.XSHG', '600741.XSHG', '600742.XSHG', '600743.XSHG', '600744.XSHG', '600746.XSHG', '600748.XSHG', '600749.XSHG', '600750.XSHG', '600751.XSHG', '600753.XSHG', '600754.XSHG', '600755.XSHG', '600756.XSHG', '600757.XSHG', '600758.XSHG', '600759.XSHG', '600760.XSHG', '600761.XSHG', '600763.XSHG', '600764.XSHG', '600765.XSHG', '600766.XSHG', '600767.XSHG', '600768.XSHG', '600769.XSHG', '600770.XSHG', '600773.XSHG', '600774.XSHG', '600775.XSHG', '600776.XSHG', '600777.XSHG', '600778.XSHG', '600779.XSHG', '600781.XSHG', '600782.XSHG', '600783.XSHG', '600785.XSHG', '600787.XSHG', '600789.XSHG', '600790.XSHG', '600791.XSHG', '600792.XSHG', '600793.XSHG', '600794.XSHG', '600796.XSHG', '600797.XSHG', '600801.XSHG', '600802.XSHG', '600803.XSHG', '600804.XSHG', '600805.XSHG', '600806.XSHG', '600808.XSHG', '600809.XSHG', '600810.XSHG', '600811.XSHG', '600812.XSHG', '600815.XSHG', '600816.XSHG', '600818.XSHG', '600819.XSHG', '600820.XSHG', '600821.XSHG', '600822.XSHG', '600823.XSHG', '600824.XSHG', '600825.XSHG', '600826.XSHG', '600827.XSHG', '600828.XSHG', '600829.XSHG', '600830.XSHG', '600831.XSHG', '600833.XSHG', '600834.XSHG', '600835.XSHG', '600836.XSHG', '600837.XSHG', '600838.XSHG', '600839.XSHG', '600841.XSHG', '600843.XSHG', '600844.XSHG', '600845.XSHG', '600846.XSHG', '600847.XSHG', '600848.XSHG', '600850.XSHG', '600851.XSHG', '600853.XSHG', '600854.XSHG', '600855.XSHG', '600856.XSHG', '600857.XSHG', '600858.XSHG', '600859.XSHG', '600860.XSHG', '600861.XSHG', '600862.XSHG', '600863.XSHG', '600864.XSHG', '600865.XSHG', '600866.XSHG', '600867.XSHG', '600868.XSHG', '600870.XSHG', '600871.XSHG', '600872.XSHG', '600873.XSHG', '600874.XSHG', '600875.XSHG', '600876.XSHG', '600877.XSHG', '600879.XSHG', '600881.XSHG', '600882.XSHG', '600883.XSHG', '600884.XSHG', '600885.XSHG', '600886.XSHG', '600887.XSHG', '600888.XSHG', '600889.XSHG', '600890.XSHG', '600891.XSHG', '600892.XSHG', '600893.XSHG', '600894.XSHG', '600895.XSHG', '600896.XSHG', '600897.XSHG', '600898.XSHG', '600900.XSHG', '600960.XSHG', '600961.XSHG', '600962.XSHG', '600963.XSHG', '600965.XSHG', '600966.XSHG', '600967.XSHG', '600969.XSHG', '600970.XSHG', '600971.XSHG', '600973.XSHG', '600975.XSHG', '600976.XSHG', '600978.XSHG', '600979.XSHG', '600980.XSHG', '600981.XSHG', '600982.XSHG', '600983.XSHG', '600984.XSHG', '600986.XSHG', '600987.XSHG', '600988.XSHG', '600990.XSHG', '600992.XSHG', '600993.XSHG', '600995.XSHG', '600997.XSHG', '600998.XSHG', '600999.XSHG', '601000.XSHG', '601001.XSHG', '601002.XSHG', '601003.XSHG', '601005.XSHG', '601006.XSHG', '601007.XSHG', '601008.XSHG', '601009.XSHG', '601010.XSHG', '601011.XSHG', '601012.XSHG', '601018.XSHG', '601028.XSHG', '601058.XSHG', '601088.XSHG', '601098.XSHG', '601099.XSHG', '601100.XSHG', '601106.XSHG', '601107.XSHG', '601113.XSHG', '601116.XSHG', '601117.XSHG', '601118.XSHG', '601126.XSHG', '601137.XSHG', '601139.XSHG', '601158.XSHG', '601166.XSHG', '601168.XSHG', '601169.XSHG', '601177.XSHG', '601179.XSHG', '601186.XSHG', '601188.XSHG', '601199.XSHG', '601208.XSHG', '601216.XSHG', '601218.XSHG', '601222.XSHG', '601231.XSHG', '601233.XSHG', '601238.XSHG', '601258.XSHG', '601288.XSHG', '601311.XSHG', '601318.XSHG', '601328.XSHG', '601333.XSHG', '601336.XSHG', '601339.XSHG', '601360.XSHG', '601369.XSHG', '601377.XSHG', '601388.XSHG', '601390.XSHG', '601398.XSHG', '601515.XSHG', '601518.XSHG', '601519.XSHG', '601555.XSHG', '601558.XSHG', '601566.XSHG', '601567.XSHG', '601588.XSHG', '601599.XSHG', '601600.XSHG', '601601.XSHG', '601607.XSHG', '601608.XSHG', '601616.XSHG', '601618.XSHG', '601628.XSHG', '601633.XSHG', '601636.XSHG', '601666.XSHG', '601668.XSHG', '601669.XSHG', '601677.XSHG', '601678.XSHG', '601688.XSHG', '601699.XSHG', '601700.XSHG', '601717.XSHG', '601718.XSHG', '601727.XSHG', '601766.XSHG', '601777.XSHG', '601788.XSHG', '601789.XSHG', '601798.XSHG', '601799.XSHG', '601800.XSHG', '601801.XSHG', '601808.XSHG', '601818.XSHG', '601857.XSHG', '601866.XSHG', '601872.XSHG', '601877.XSHG', '601880.XSHG', '601886.XSHG', '601888.XSHG', '601890.XSHG', '601898.XSHG', '601899.XSHG', '601901.XSHG', '601908.XSHG', '601918.XSHG', '601919.XSHG', '601928.XSHG', '601929.XSHG', '601933.XSHG', '601939.XSHG', '601958.XSHG', '601965.XSHG', '601988.XSHG', '601989.XSHG', '601991.XSHG', '601992.XSHG', '601996.XSHG', '601998.XSHG', '601999.XSHG', '603000.XSHG', '603001.XSHG', '603002.XSHG', '603008.XSHG', '603077.XSHG', '603123.XSHG', '603128.XSHG', '603333.XSHG', '603366.XSHG', u'HY530', u'HY531', u'HY578', u'HY470', u'HY483', u'HY480', u'HY481', u'HY486', u'HY487', u'HY484', u'HY485', u'HY488', u'HY489', u'HY588', u'HY570', u'HY501', u'HY500', u'HY506', u'HY505', u'HY504', u'HY509', u'HY527', u'HY510', u'HY437', u'HY436', u'HY435', u'HY434', u'HY433', u'HY432', u'HY439', u'HY438', u'HY455', u'HY454', u'HY457', u'HY518', u'HY519', u'HY453', u'HY452', u'HY514', u'HY515', u'HY516', u'HY517', u'HY459', u'HY511', u'HY512', u'HY513', u'HY526', u'HY420', u'HY421', u'HY422', u'HY423', u'HY424', u'HY425', u'HY426', u'HY427', u'HY428', u'HY429', u'HY587', u'HY446', u'HY447', u'HY444', u'HY445', u'HY442', u'HY443', u'HY440', u'HY441', u'HY406', u'HY407', u'HY448', u'HY449', u'HY595', u'HY596', u'HY597', u'HY591', u'HY593', u'HY598', u'HY458', u'HY473', u'HY472', u'HY471', u'HY579', u'HY477', u'HY476', u'HY474', u'HY572', u'HY573', u'HY479', u'HY478', u'HY576', u'HY574', u'HY451', u'HY450', u'HY468', u'HY469', u'HY464', u'HY465', u'HY466', u'HY467', u'HY460', u'HY461', u'HY462', u'HY463', u'HY571', u'HY601', u'HY419', u'HY418', u'HY411', u'HY410', u'HY413', u'HY412', u'HY415', u'HY414', u'HY417', u'HY416', u'HY525', u'HY524', u'HY408', u'HY409', u'HY521', u'HY520', u'HY523', u'HY402', u'HY403', u'HY401', u'HY529', u'HY528', u'HY404', u'HY405', u'HY491', u'HY493', u'HY492', u'HY494', u'HY497', u'HY496')]

注意传入的数据结构和axis的值,我这边测试没有问题,不是行业的问题

@薛定谔の喵 是不是系统出问题了吗，代码没有任何改动，之前运行都好好的，现在一直报错 Traceback (most recent call last): File "jqboson/core/entry.py", line 375, in jqboson.core.entry._run (jqboson/core/entry.c:8921) File "jqboson/core/engine.py", line 240, in jqboson.core.engine.Engine.start (jqboson/core/engine.c:5975) File "jqboson/core/dispatcher.py", line 209, in jqboson.core.dispatcher.Dispatcher.start (jqboson/core/dispatcher.c:4952) File "jqboson/core/dispatcher.py", line 189, in jqboson.core.dispatcher.Dispatcher._loop (jqboson/core/dispatcher.c:4292) File "jqboson/core/bus.py", line 35, in jqboson.core.bus.EventBus.emit (jqboson/core/bus.c:1733) File "jqboson/core/strategy.py", line 250, in jqboson.core.strategy.Strategy._cb_wrapper._wrapper (jqboson/core/strategy.c:5835) File "jqboson/core/strategy.py", line 251, in jqboson.core.strategy.Strategy._cb_wrapper._wrapper (jqboson/core/strategy.c:5778) File "/tmp/strategy/user_code.py", line 63, in fun_main fdf = get_factors(g.feasible_stocks, context, g.factors,startdate) File "/tmp/strategy/user_code.py", line 370, in get_factors aa = globals()[tmp](stocks_list,context,fdate)#,value) File "/tmp/strategy/user_code.py", line 439, in get_df_BP df_BP=neutralize(df_BP, how=['jq_l1'], date=fdate, axis=0) File "jqfactor/__init__.py", line 295, in neutralize return neutralize(data, how=how, date=date, axis=axis) File "jqfactor/preprocess.py", line 193, in jqfactor.preprocess.neutralize (jqfactor/preprocess.c:6540) File "jqfactor/preprocess.py", line 187, in jqfactor.preprocess.neutralize.extend_industry_code (jqfactor/preprocess.c:4821) TypeError: get_industries() takes no keyword arguments

您能提供一下测试代码吗?因为我这边测试,只要输入的数据是符合结构的,就不会报错

@薛定谔の喵 import pandas as pd from pandas import Series, DataFrame import numpy as np import statsmodels.api as sm import scipy.stats as scs import matplotlib.pyplot as plt import datetime as dt from jqdata import * import time from jqfactor import winsorize from jqfactor import standardlize from jqfactor import neutralize def initialize(context): #用沪深 300 做回报基准 set_benchmark('000001.XSHG') # 滑点、真实价格 #set_slippage(FixedSlippage(0.000)) set_option('use_real_price', True) g.index='000001.XSHG' # 定义股票池，上交所股票 # 关闭部分log log.set_level('order', 'error') #g.factors = ['B/M','EPS','PEG','ROE','ROA','GP/R','P/R','L/A','FAP','CMV'] run_daily(fun_main, '9:30') g.shift = 21 # 设置一个观测天数（天数） g.factors = ['CMV','BP','EP','NPOR','FLUC','NPORC','MTM1','MTM3','MTM6','MTM12','ALR','FACR','DP','PEG','CFP'] #g.factors = ['PS','ROA','ROAC','ROE','ROEC','OPTP','OPTPC','OPOR','OPORC','CMV','TR','TRC','VAR','VARC','reverse'] #g.factors = ['PEG','CMV'] #g.factors = ['ROA','ROAC','CMV'] pd.set_option('display.max_rows', 10000) pd.set_option('display.max_columns', 10000) #pd.set_option('display.width', 10000) def fun_main(context): #因为研究模块取fundmental数据默认date为研究日期的前一天。所以要自备时间序列。按月取 #year = ['2011','2012'] year = ['2008','2009','2010','2011','2012'] #year = ['2012','2013','2014','2015','2016'] #year = ['2009','2010','2011','2012','2013','2014','2015','2016'] #year = ['2012','2013','2014','2015','2016','2017','2018'] #year = ['2006','2007','2008','2009','2010','2011','2012'] month = ['01','02','03','04','05','06','07','08','09','10','11','12'] result = {} #factors = ['BP','EP','PEG','CFP','PS','ROA','ROAC','ROE','ROEC','OPTP','OPTPC','OPOR','OPORC','CMC','TR','TRC','VAR','VARC','reverse'] for i in range((len(year)-1)*12): startdate = year[i/12] + '-' + month[i%12] + '-01' try: enddate = year[(i+1)/12] + '-' + month[(i+1)%12] + '-01' except IndexError: enddate = '2012-01-01' try: nextdate = year[(i+2)/12] + '-' + month[(i+2)%12] + '-01' except IndexError: if enddate == '2012-01-01': nextdate = '2012-02-01' else: nextdate = '2012-01-01' print 'time %s'%startdate #fdf = get_factors(startdate,factors) g.feasible_stocks = set_feasible_stocks(get_index_stocks(g.index), g.shift,context,startdate) #g.feasible_stocks = filter_specials(g.feasible_stocks)#[g.num_stocks:g.num_stocksplus] g.feasible_stocks = delNew(context, g.feasible_stocks, 90,startdate) fdf = get_factors(g.feasible_stocks, context, g.factors,startdate) #print "--------------------------------factors-----------------------------------" #print fdf CMV = fdf['CMV'] #print "--------------------------------CMV-----------------------------------" #print CMV factors_length= len(g.factors) #print factors_length #5个组合，19个因子 df = DataFrame(np.zeros(6*factors_length).reshape(6,factors_length),index = ['port1','port2','port3','port4','port5','benchmark'],columns = g.factors) #5个组合，2个因子 #df = DataFrame(np.zeros(6*2).reshape(6,2),index = ['port1','port2','port3','port4','port5','benchmark'],columns = g.factors) #5个组合，3个因子 #df = DataFrame(np.zeros(6*3).reshape(6,3),index = ['port1','port2','port3','port4','port5','benchmark'],columns = g.factors) for fac in g.factors: score = fdf[fac].order() port1 = list(score.index)[: len(score)/5] port2 = list(score.index)[ len(score)/5: 2*len(score)/5] port3 = list(score.index)[ 2*len(score)/5: 3*len(score)/5] port4 = list(score.index)[ 3*len(score)/5: 4*len(score)/5] port5 = list(score.index)[ 4*len(score)/5: ] df.ix['port1',fac] = caculate_port_monthly_return(port1,startdate,enddate,nextdate,CMV) df.ix['port2',fac] = caculate_port_monthly_return(port2,startdate,enddate,nextdate,CMV) df.ix['port3',fac] = caculate_port_monthly_return(port3,startdate,enddate,nextdate,CMV) df.ix['port4',fac] = caculate_port_monthly_return(port4,startdate,enddate,nextdate,CMV) df.ix['port5',fac] = caculate_port_monthly_return(port5,startdate,enddate,nextdate,CMV) df.ix['benchmark',fac] = caculate_benchmark_monthly_return(startdate,enddate,nextdate) #print 'factor %s'%fac result[i+1]=df monthly_return = pd.Panel(result) #monthly_return[:,:,'L/A'] #(monthly_return[:,:,'L/A'].T+1).cumprod().tail() factors_value = {} total_return = {} annual_return = {} excess_return = {} win_prob = {} loss_prob = {} effect_test = {} MinCorr = 0.3 Minbottom = -0.05 Mintop = 0.05 for fac in g.factors: effect_test[fac] = {} monthly = monthly_return[:,:,fac] total_return[fac] = (monthly+1).T.cumprod().iloc[-1,:]-1 annual_return[fac] = (total_return[fac]+1)**(1./(len(year)-1))-1 excess_return[fac] = annual_return[fac]- annual_return[fac][-1] print "--------------------------------monthly-----------------------------------" print monthly print "--------------------------------total_return-----------------------------------" print fac print total_return[fac] print "===============================annual_return==============================" print fac print annual_return[fac] print "-------------------------------excess_return------------------------------" print excess_return[fac] #判断因子有效性 #1.年化收益与组合序列的相关性 大于 阀值 effect_test[fac][1] = annual_return[fac][0:5].corr(Series([1,2,3,4,5],index = annual_return[fac][0:5].index)) #dfe=pd.DataFrame(annual_return[fac][0:5]) #s = Series([1,2,3,4,5],index=["port1","port2","port3","port4","port5"]) #effect_test[fac][1] = dfe.corrwith(s).values #print "-------------------------------effect_test[fac][1]------------------------------" #print type(effect_test[fac][1]) #print effect_test[fac][1] #2.高收益组合跑赢概率 #因子小，收益小，port1是输家组合，port5是赢家组合 AR1<ARn if total_return[fac][0] < total_return[fac][-2]: factors_value[fac] = True loss_excess = monthly.iloc[0,:]-monthly.iloc[-1,:] loss_prob[fac] = loss_excess[loss_excess<0].count()/float(len(loss_excess)) win_excess = monthly.iloc[-2,:]-monthly.iloc[-1,:] win_prob[fac] = win_excess[win_excess>0].count()/float(len(win_excess)) effect_test[fac][3] = [win_prob[fac],loss_prob[fac]] #超额收益 effect_test[fac][2] = [excess_return[fac][-2]*100,excess_return[fac][0]*100] #因子小，收益大，port1是赢家组合，port5是输家组合 else: factors_value[fac] = False loss_excess = monthly.iloc[-2,:]-monthly.iloc[-1,:] loss_prob[fac] = loss_excess[loss_excess<0].count()/float(len(loss_excess)) win_excess = monthly.iloc[0,:]-monthly.iloc[-1,:] win_prob[fac] = win_excess[win_excess>0].count()/float(len(win_excess)) effect_test[fac][3] = [win_prob[fac],loss_prob[fac]] #超额收益 effect_test[fac][2] = [excess_return[fac][0]*100,excess_return[fac][-2]*100] #effect_test[1]记录因子相关性，>0.5或<-0.5合格 #effect_test[2]记录【赢家组合超额收益，输家组合超额收益】 #effect_test[3]记录赢家组合跑赢概率和输家组合跑输概率。【>0.5,>0.4】合格(因实际情况，跑输概率暂时不考虑) DataFrame(effect_test) print DataFrame(effect_test) print "===============================factors_value==============================" print factors_value #effective_factors = ['B/M','PEG','P/R','FAP','CMV'] #DataFrame(total_return).ix[:,effective_factors] #DataFrame(annual_return).ix[:,effective_factors] # 某一日的前shift个交易日日期 # 输入：date为datetime.date对象(是一个date，而不是datetime)；shift为int类型 # 输出：datetime.date对象(是一个date，而不是datetime) def shift_trading_day(date, shift): # 获取所有的交易日，返回一个包含所有交易日的 list,元素值为 datetime.date 类型. tradingday = get_all_trade_days() y=int(date[0:4]) m=int(date[5:7]) d=int(date[-2:]) # 得到date之后shift天那一天在列表中的行标号 返回一个数 if date in tradingday: shiftday_index = list(tradingday).index(date)+shift #print "===============================shiftday_index1==============================" #print '(shiftday_index1 % s)' % tradingday[shiftday_index] return tradingday[shiftday_index] # 根据行号返回该日日期 为datetime.date类型 elif (datetime.date(y,m,d) + timedelta(1)) in tradingday: shiftday_index = list(tradingday).index(datetime.date(y,m,d) + timedelta(1))+shift #print "===============================shiftday_index2==============================" #print '(shiftday_index2 % s)' % tradingday[shiftday_index] return tradingday[shiftday_index] elif (datetime.date(y,m,d) + timedelta(2)) in tradingday: shiftday_index = list(tradingday).index(datetime.date(y,m,d) + timedelta(2))+shift #print "===============================shiftday_index3==============================" #print '(shiftday_index3 % s)' % tradingday[shiftday_index] return tradingday[shiftday_index] elif (datetime.date(y,m,d) + timedelta(3)) in tradingday: shiftday_index = list(tradingday).index(datetime.date(y,m,d) + timedelta(3))+shift #print "===============================shiftday_index4==============================" #print '(shiftday_index4 % s)' % tradingday[shiftday_index] return tradingday[shiftday_index] elif (datetime.date(y,m,d) + timedelta(4)) in tradingday: shiftday_index = list(tradingday).index(datetime.date(y,m,d) + timedelta(4))+shift #print "===============================shiftday_index5==============================" #print '(shiftday_index5 % s)' % tradingday[shiftday_index] return tradingday[shiftday_index] elif (datetime.date(y,m,d) + timedelta(5)) in tradingday: shiftday_index = list(tradingday).index(datetime.date(y,m,d) + timedelta(5))+shift #print "===============================shiftday_index6==============================" #print '(shiftday_index6 % s)' % tradingday[shiftday_index] return tradingday[shiftday_index] elif (datetime.date(y,m,d) + timedelta(6)) in tradingday: shiftday_index = list(tradingday).index(datetime.date(y,m,d) + timedelta(6))+shift #print "===============================shiftday_index7==============================" #print '(shiftday_index7 % s)' % tradingday[shiftday_index] return tradingday[shiftday_index] elif (datetime.date(y,m,d) + timedelta(7)) in tradingday: shiftday_index = list(tradingday).index(datetime.date(y,m,d) + timedelta(7))+shift #print "===============================shiftday_index8==============================" #print '(shiftday_index8 % s)' % tradingday[shiftday_index] return tradingday[shiftday_index] elif (datetime.date(y,m,d) + timedelta(8)) in tradingday: shiftday_index = list(tradingday).index(datetime.date(y,m,d) + timedelta(8))+shift #print "===============================shiftday_index9==============================" #print '(shiftday_index8 % s)' % tradingday[shiftday_index] return tradingday[shiftday_index] elif (datetime.date(y,m,d) + timedelta(9)) in tradingday: shiftday_index = list(tradingday).index(datetime.date(y,m,d) + timedelta(9))+shift #print "===============================shiftday_index10==============================" #print '(shiftday_index8 % s)' % tradingday[shiftday_index] return tradingday[shiftday_index] elif (datetime.date(y,m,d) + timedelta(10)) in tradingday: shiftday_index = list(tradingday).index(datetime.date(y,m,d) + timedelta(10))+shift #print "===============================shiftday_index11==============================" #print '(shiftday_index8 % s)' % tradingday[shiftday_index] return tradingday[shiftday_index] elif (datetime.date(y,m,d) + timedelta(11)) in tradingday: shiftday_index = list(tradingday).index(datetime.date(y,m,d) + timedelta(11))+shift #print "===============================shiftday_index12==============================" #print '(shiftday_index8 % s)' % tradingday[shiftday_index] return tradingday[shiftday_index] else: print "===============================shiftday_index4==============================" print 'ooooo' # 过滤掉当日停牌的股票,且筛选出前days天未停牌股票 # 输入：stock_list为list类型,样本天数days为int类型，context（见API） # 输出：list=g.feasible_stocks def set_feasible_stocks(stock_list,days,context,fdate): # 得到是否停牌信息的dataframe，停牌的1，未停牌得0 start_date1=shift_trading_day(fdate,shift = 0) suspened_info_df = get_price(list(stock_list), start_date=shift_trading_day(fdate,shift = 0), end_date=shift_trading_day(fdate,shift = 0), frequency='daily', fields='paused' )['paused'] ''' suspened_info_df66 = get_price('600155.XSHG', start_date=shift_trading_day(fdate,shift = 0), end_date=shift_trading_day(fdate,shift = 0), frequency='daily', fields='paused' )['paused'] print"===============================suspened_info_df66==============================" print suspened_info_df66 ''' suspened_info_df = suspened_info_df.dropna(axis=1) #print "===============================suspened_info_df1==============================" #print type(suspened_info_df) #print '(start_date1 % s)' % fdate #print suspened_info_df #print len(suspened_info_df) suspened_info_df = suspened_info_df.T #print"===============================len2==============================" #print len(suspened_info_df) #print "===============================suspened_info_df==============================" #print type(suspened_info_df) #print suspened_info_df # 过滤停牌股票 返回dataframe unsuspened_index = suspened_info_df.iloc[:,0]<1 #print "===============================unsuspened_index==============================" #print type(unsuspened_index) #print len(unsuspened_index) #print unsuspened_index[600155.XSHG] # 得到当日未停牌股票的代码list: #aa=suspened_info_df[unsuspened_index] unsuspened_stocks = suspened_info_df[unsuspened_index].index #print aa #print type(unsuspened_stocks) #print len(unsuspened_stocks) #unsuspened_stocks = unsuspened_index.index # 进一步，筛选出前days天未曾停牌的股票list: feasible_stocks = [] #current_data = get_current_data() for stock in unsuspened_stocks: df = get_price(stock, end_date = shift_trading_day(fdate,shift = 0), frequency='daily', fields='paused', skip_paused = False, count= days )['paused'] if sum(df)== 0: feasible_stocks.append(stock) #print "===============================df==============================" #print sum(df) #print 'sum(df)% f' % sum(df)[0] ''' try: for stock in unsuspened_stocks: if sum(get_price(stock, end_date = shift_trading_day(fdate,shift = 0), frequency='daily', fields='paused', skip_paused = False, count= days )['paused'] ) == 0: feasible_stocks.append(stock) except: pass ''' #print "===============================feasible_stocks==============================" #print feasible_stocks return feasible_stocks ## 过滤停牌 退市 st股票 当日未涨跌停股票 def filter_specials(stock_list): curr_data = get_current_data() stock_list = [stock for stock in stock_list if \ (not curr_data[stock].paused) # 未停牌 and (not curr_data[stock].is_st) # 非ST and ('ST' not in curr_data[stock].name) and ('*' not in curr_data[stock].name) and ('退' not in curr_data[stock].name) and (curr_data[stock].low_limit < curr_data[stock].day_open < curr_data[stock].high_limit) # 未涨跌停 ] return stock_list ##过滤上市时间短于deltaday 天的股票 def delNew(context,security_list, deltaday,fdate): y=int(fdate[0:4]) m=int(fdate[5:7]) d=int(fdate[-2:]) #print y,m,d deltaDate = datetime.date(y,m,d) - timedelta(deltaday) tmpList = [] for stock in security_list: if get_security_info(stock).start_date < deltaDate: tmpList.append(stock) return tmpList def get_factors(stocks_list, context, factors,fdate): # 从可行股票池中生成股票代码列表 df_all_raw = pd.DataFrame(stocks_list) # 修改index为股票代码 df_all_raw['code'] = df_all_raw[0] df_all_raw.index = df_all_raw.code # 格式调整，没有一步到位中间有些东西还在摸索，简洁和效率的一个权衡 del df_all_raw[0] #print "-------------1111111111111-------------------------------------------" #print df_all_raw stocks_list300 = list(df_all_raw.index) # 每一个指标量都合并到一个dataframe里 for key in g.factors: # 构建一个新的字符串，名字叫做 'get_df_'+ 'key' tmp='get_df' + '_' + key # 声明字符串是个方程 aa = globals()[tmp](stocks_list,context,fdate)#,value) # 合并处理 df_all_raw = pd.concat([df_all_raw,aa], axis=1) # 删除code列 del df_all_raw['code'] # 对于新生成的股票代码取list stocks_list_more = list(df_all_raw.index) # 可能在计算过程中并如的股票剔除 for stock in stocks_list_more[:]: if stock not in stocks_list300: df_all_raw.drop(stock) if len(g.factors) >4: df_all_raw=df_all_raw.dropna(how='all') #多因子 else: df_all_raw=df_all_raw.dropna() #单因子 #print "-------------meanmeanmean-------------------------------------------" #print df_all_raw b = df_all_raw.mean(axis=0) c = df_all_raw.describe() values = {} #print "-------------------------------平均值-------------------------------------" #print b #print "-----------------------------综述-------------------------------------------" #print c #print df_all_raw for i in range(len(g.factors)): a = b[i] values[g.factors[i]] = a #print "-------------aaaaaaaaaaaa-------------------------------------------" #print values #df_all_raw.fillna(value={g.factors[i]:a}) df_all_raw=df_all_raw.fillna(value=values) #df_all_raw=df_all_raw.dropna() #print "-------------meanmeanmean-------------------------------------------" #print df_all_raw return df_all_raw # 1BP # 得到一个dataframe：包含股票代码、账面市值比BP和对应排名BP_sorted_rank # 默认date = context.current_dt的前一天,使用默认值，避免未来函数，不建议修改 # 获得市净率pb_ratio def get_df_BP(stock_list, context,fdate):#, asc): df_BP = get_fundamentals(query(valuation.code, valuation.pb_ratio ).filter(valuation.code.in_(stock_list)), date=fdate) # 获得pb倒数 df_BP['BP'] = df_BP['pb_ratio'].apply(lambda x: 1/x) # 删除nan，以备数据中某项没有产生nan #df_BP = df_BP[pd.notnull(df_BP['BP'])] df_BP['BP'] = df_BP['BP'].dropna() # 生成排名序数 #df_BP['BP_sorted_rank'] = df_BP['BP'].rank(ascending = asc, method = 'dense') # 使用股票代码作为index df_BP.index = df_BP.code # 删除无用数据 del df_BP['code'] del df_BP['pb_ratio'] df_BP=winsorize(df_BP, scale=3, inclusive=True, inf2nan=True, axis=0) #print "--------------------------------BP去极值-----------------------------------" #print df_BP #df_BP1= neutralize(df_BP, how=['jq_l1', 'market_cap'], date=fdate, axis=0) #df_BP2=standardlize(df_BP1, inf2nan=True, axis=0) #df_BP['BPN']=df_BP1['BP'] #df_BP['BPS']=df_BP2['BP'] #print "--------------------------------BP中性化-----------------------------------" #print df_BP df_BP=neutralize(df_BP, how=['jq_l1'], date=fdate, axis=0) df_BP=standardlize(df_BP, inf2nan=True, axis=0) #mean = df_BP['BP'].mean #df_BP['BP'] = df_BP['BP'].fillna(mean) #print "--------------------------------BP-----------------------------------" #print df_BP return df_BP # 2EP # 得到一个dataframe：包含股票代码、盈利收益率EP和EP_sorted_rank # 默认date = context.current_dt的前一天,使用默认值，避免未来函数，不建议修改 # 获得动态市盈率pe_ratio def get_df_EP(stock_list, context,fdate):#, asc): df_EP = get_fundamentals(query(valuation.code, valuation.pe_ratio ).filter(valuation.code.in_(stock_list)), date=fdate) # 获得pe倒数 df_EP['EP'] = df_EP['pe_ratio'].apply(lambda x: 1/x) # 删除nan，以备数据中某项没有产生nan df_EP = df_EP[pd.notnull(df_EP['EP'])] # 复制一个dataframe，按对应项目排序 #df_EP['EP_sorted_rank'] = df_EP['EP'].rank(ascending = asc, method = 'dense') # 使用股票代码作为index df_EP.index = df_EP.code # 删除无用数据 del df_EP['code'] del df_EP['pe_ratio'] #mean = df_EP['EP'].mean #df_EP['EP'] = df_EP['EP'].fillna(mean) df_EP=winsorize(df_EP, scale=3, inclusive=True, inf2nan=True, axis=0) df_EP=neutralize(df_EP, how=['jq_l1'], date=fdate, axis=0) df_EP=standardlize(df_EP, inf2nan=True, axis=0) #print "--------------------------------EP-----------------------------------" #print df_EP return df_EP # 3PEG # 输入：context(见API)；stock_list为list类型，表示股票池 # 输出：df_PEG为dataframe: index为股票代码，data为相应的PEG值 def get_df_PEG(stock_list, context,fdate):#, asc): # 查询股票池里股票的市盈率，收益增长率 q_PE_G = query(valuation.code, valuation.pe_ratio, indicator.inc_net_profit_year_on_year ).filter(valuation.code.in_(stock_list)) # 得到一个dataframe：包含股票代码、市盈率PE、收益增长率G # 默认date = context.current_dt的前一天,使用默认值，避免未来函数，不建议修改 df_PE_G = get_fundamentals(q_PE_G, date=fdate) # 筛选出成长股：删除市盈率或收益增长率为负值的股票 df_Growth_PE_G = df_PE_G[(df_PE_G.pe_ratio >0)&(df_PE_G.inc_net_profit_year_on_year >0)] # 去除PE或G值为非数字的股票所在行 df_Growth_PE_G.dropna() # 得到一个Series：存放股票的市盈率TTM，即PE值 Series_PE = df_Growth_PE_G.ix[:,'pe_ratio'] # 得到一个Series：存放股票的收益增长率，即G值 Series_G = df_Growth_PE_G.ix[:,'inc_net_profit_year_on_year'] # 得到一个Series：存放股票的PEG值 Series_PEG = Series_PE/Series_G # 将股票与其PEG值对应 Series_PEG.index = df_Growth_PE_G.ix[:,0] # 生成空dataframe df_PEG = pd.DataFrame(Series_PEG) # 将Series类型转换成dataframe类型 df_PEG['PEG'] = pd.DataFrame(Series_PEG) # 得到一个dataframe：包含股票代码、盈利收益率PEG和PEG_sorted_rank # 赋予顺序排列PEG数据序数编号 #df_PEG['PEG_sorted_rank'] = df_PEG['PEG'].rank(ascending = asc, method = 'dense') # 删除不需要列 df_PEG = df_PEG.drop(0, 1) df_PEG = df_PEG.dropna() df_PEG=winsorize(df_PEG, scale=3, inclusive=True, inf2nan=True, axis=0) df_PEG=neutralize(df_PEG, how=['jq_l1'], date=fdate, axis=0) df_PEG=standardlize(df_PEG, inf2nan=True, axis=0) #print "--------------------------------PEG-----------------------------------" #print df_PEG return df_PEG # 4DP # 得到一个dataframe：包含股票代码、股息率(DP)和DP_sorted_rank # 默认date = context.current_dt的前一天,使用默认值，避免未来函数，不建议修改 def get_df_DP(stock_list, context,fdate):#, asc): # 获得dividend_payable和market_cap 应付股利(元)和总市值(亿元) df_DP = get_fundamentals(query(balance.code, balance.dividend_payable, valuation.market_cap ).filter(balance.code.in_(stock_list)), date=fdate) # 按公式计算 df_DP['DP'] = df_DP['dividend_payable']/(df_DP['market_cap']*100000000) # 删除nan df_DP = df_DP.dropna() # 生成排名序数 #df_DP['DP_sorted_rank'] = df_DP['DP'].rank(ascending = asc, method = 'dense') # 使用股票代码作为index df_DP.index = df_DP.code # 删除无用数据 del df_DP['code'] del df_DP['dividend_payable'] del df_DP['market_cap'] # 改个名字 df_DP.columns = ['DP']#, 'DP_sorted_rank'] df_DP=winsorize(df_DP, scale=3, inclusive=True, inf2nan=True, axis=0) df_DP=neutralize(df_DP, how=['jq_l1'], date=fdate, axis=0) df_DP=standardlize(df_DP, inf2nan=True, axis=0) #print "--------------------------------DP-----------------------------------" #print df_DP return df_DP # 5CFP # 得到一个dataframe：包含股票代码、现金收益率CFP和CFP_sorted_rank # 默认date = context.current_dt的前一天,使用默认值，避免未来函数，不建议修改 def get_df_CFP(stock_list, context,fdate):#, asc): # 获得市现率pcf_ratio cashflow/price df_CFP = get_fundamentals(query(valuation.code, valuation.pcf_ratio ).filter(valuation.code.in_(stock_list)), date=fdate) # 获得pcf倒数 df_CFP['CFP'] = df_CFP['pcf_ratio'].apply(lambda x: 1/x) # 删除nan，以备数据中某项没有产生nan df_CFP = df_CFP[pd.notnull(df_CFP['CFP'])] # 生成序列数字排名 #df_CFP['CFP_sorted_rank'] = df_CFP['CFP'].rank(ascending = asc, method = 'dense') # 使用股票代码作为index df_CFP.index = df_CFP.code # 删除无用数据 del df_CFP['pcf_ratio'] del df_CFP['code'] df_CFP=winsorize(df_CFP, scale=3, inclusive=True, inf2nan=True, axis=0) df_CFP=neutralize(df_CFP, how=['jq_l1'], date=fdate, axis=0) df_CFP=standardlize(df_CFP, inf2nan=True, axis=0) #print "--------------------------------CFP-----------------------------------" #print df_CFP return df_CFP # 6PS # 得到一个dataframe：包含股票代码、P/SALES（PS市销率TTM）和PS_sorted_rank # 默认date = context.current_dt的前一天,使用默认值，避免未来函数，不建议修改 def get_df_PS(stock_list, context,fdate):#, asc): # 获得市销率TTMps_ratio df_PS = get_fundamentals(query(valuation.code, valuation.ps_ratio ).filter(valuation.code.in_(stock_list)), date=fdate) # 删除nan，以备数据中某项没有产生nan df_PS = df_PS[pd.notnull(df_PS['ps_ratio'])] # 生成排名序数 #df_PS['PS_sorted_rank'] = df_PS['ps_ratio'].rank(ascending = asc, method = 'dense') # 使用股票代码作为index df_PS.index = df_PS.code # 删除无用数据 del df_PS['code'] # 改个名字 df_PS.columns = ['PS']#, 'PS_sorted_rank'] df_PS=winsorize(df_PS, scale=3, inclusive=True, inf2nan=True, axis=0) df_PS=neutralize(df_PS, how=['jq_l1'], date=fdate, axis=0) df_PS=standardlize(df_PS, inf2nan=True, axis=0) #print "--------------------------------PS-----------------------------------" #print df_PS return df_PS # 7ALR # 得到一个dataframe：包含股票代码、资产负债率(asset-liability ratio, ALR) # 和ALR_sorted_rank # 默认date = context.current_dt的前一天,使用默认值，避免未来函数，不建议修改 def get_df_ALR(stock_list, context,fdate):#, asc): # 获得total_liability和total_assets 负债合计(元)和资产总计(元) df_ALR = get_fundamentals(query(balance.code, balance.total_liability, balance.total_assets ).filter(balance.code.in_(stock_list)), date=fdate) # 复制一个dataframe，按对应项目排序 df_ALR['ALR'] = df_ALR['total_liability']/df_ALR['total_assets'] # 删除nan df_ALR = df_ALR.dropna() # 生成排名序数 #df_ALR['ALR_sorted_rank'] = df_ALR['ALR'].rank(ascending = asc, method = 'dense') # 使用股票代码作为index df_ALR.index = df_ALR.code # 删除无用数据 del df_ALR['code'] del df_ALR['total_liability'] del df_ALR['total_assets'] df_ALR=winsorize(df_ALR, scale=3, inclusive=True, inf2nan=True, axis=0) df_ALR=neutralize(df_ALR, how=['jq_l1'], date=fdate, axis=0) df_ALR=standardlize(df_ALR, inf2nan=True, axis=0) #print "--------------------------------ALR-----------------------------------" #print df_ALR return df_ALR # 8FACR # 得到一个dataframe：包含股票代码、固定资产比例(fixed assets to capital ratio, FACR ) # 和FACR_sorted_rank # 默认date = context.current_dt的前一天,使用默认值，避免未来函数，不建议修改 def get_df_FACR(stock_list, context,fdate):#, asc): # 获得fixed_assets和total_assets 固定资产(元)和资产总计(元) df_FACR = get_fundamentals(query(balance.code, balance.fixed_assets, balance.total_assets ).filter(balance.code.in_(stock_list)), date=fdate) # 根据公式计算 df_FACR['FACR'] = df_FACR['fixed_assets']/df_FACR['total_assets'] # 删除nan df_FACR = df_FACR.dropna() # 生成排名序数 #df_FACR['FACR_sorted_rank'] = df_FACR['FACR'].rank(ascending = asc, method = 'dense') # 使用股票代码作为index df_FACR.index = df_FACR.code # 删除无用数据 del df_FACR['code'] del df_FACR['fixed_assets'] del df_FACR['total_assets'] # 改个名字 df_FACR.columns = ['FACR']#, 'FACR_sorted_rank'] df_FACR=winsorize(df_FACR, scale=3, inclusive=True, inf2nan=True, axis=0) df_FACR=neutralize(df_FACR, how=['jq_l1'], date=fdate, axis=0) df_FACR=standardlize(df_FACR, inf2nan=True, axis=0) #print "--------------------------------FACR-----------------------------------" #print df_FACR return df_FACR # 9ROA # 得到一个dataframe：包含股票代码、总资产净利率ROA(%)ROA(%)ROA和ROA_sorted_rank # 默认date = context.current_dt的前一天,使用默认值，避免未来函数，不建议修改 def get_df_ROA(stock_list, context,fdate):#, asc): # 获得总资产净利率ROA(%)roa需要的相关数据 df_ROA = get_fundamentals(query(indicator.code, # 负债和股东权益合计 balance.total_sheet_owner_equities, # 净利润(元) income.net_profit, # 所得税费用(元) income.income_tax_expense, # 应付利息(元) balance.interest_payable ).filter(indicator.code.in_(stock_list)), date=fdate) # 删除nan df_ROA = df_ROA.dropna() # 生成ROA数据 # ROA等于（净利润+所得税+利息费用）/负债和股东权益合计 df_ROA['ROA'] = (df_ROA['net_profit'] + df_ROA['income_tax_expense'] + df_ROA['interest_payable'] )/df_ROA['total_sheet_owner_equities'] # 生成排名序数 #df_ROA['ROA_sorted_rank'] = df_ROA['ROA'].rank(ascending = asc, method = 'dense') # 使用股票代码作为index df_ROA.index = df_ROA.code # 删除无用数据 del df_ROA['code'] del df_ROA['net_profit'] del df_ROA['income_tax_expense'] del df_ROA['interest_payable'] del df_ROA['total_sheet_owner_equities'] df_ROA=winsorize(df_ROA, scale=3, inclusive=True, inf2nan=True, axis=0) df_ROA=neutralize(df_ROA, how=['jq_l1'], date=fdate, axis=0) df_ROA=standardlize(df_ROA, inf2nan=True, axis=0) #print "--------------------------------ROA-----------------------------------" #print df_ROA return df_ROA # 10ROAC # 得到一个dataframe：包含股票代码、净资产收益率ROA变动ROA_change(ROAC)和ROAC_sorted_rank def get_df_ROAC(stock_list, context,fdate):#, asc): # 前一个交易日 yest = context.previous_date # 大约一个季度前 days_4shift_before = shift_trading_day(fdate, shift = -90) # 获得市现率roa df_ROAC = get_fundamentals(query(indicator.code, # 负债和股东权益合计 balance.total_sheet_owner_equities, # 净利润(元) income.net_profit, # 所得税费用(元) income.income_tax_expense, # 应付利息(元) balance.interest_payable ).filter(indicator.code.in_(stock_list)), days_4shift_before ) # 用股票代码作为index df_ROAC.index = df_ROAC['code'] # 删除nan df_ROAC = df_ROAC.dropna() # 生成ROA数据，小写roa为90天前数据 # roa等于（净利润+所得税+利息费用）/负债和股东权益合计 df_ROAC['roa'] = (df_ROAC['net_profit'] + df_ROAC['income_tax_expense'] + df_ROAC['interest_payable'] )/df_ROAC['total_sheet_owner_equities'] del df_ROAC['income_tax_expense'] del df_ROAC['interest_payable'] del df_ROAC['total_sheet_owner_equities'] del df_ROAC['net_profit'] del df_ROAC['code'] df_ROAC = df_ROAC.dropna() #print "--------------------------------ROAC1-----------------------------------" #print df_ROAC # 获取当期roa，顺序无影响，随意假设 df_ROA = get_df_ROA(stock_list, context,fdate) # ROA大写为当期值，roa小写为4个shift前的对应数据 df_ROAC['ROA'] = df_ROA['ROA'] # 计算ROA变动 df_ROAC['ROAC'] = df_ROAC['roa'] - df_ROAC['ROA'] # 删除nan df_ROAC = df_ROAC.dropna() # 生成序数序号 #df_ROAC['ROAC_sorted_rank'] = df_ROAC['ROAC'].rank(ascending = asc, method = 'dense') # 使用股票代码作为index #df_ROAC.index = df_ROAC.code # 删除无用数据 del df_ROAC['roa'] del df_ROAC['ROA'] df_ROAC=winsorize(df_ROAC, scale=3, inclusive=True, inf2nan=True, axis=0) df_ROAC=neutralize(df_ROAC, how=['jq_l1'], date=fdate, axis=0) df_ROAC=standardlize(df_ROAC, inf2nan=True, axis=0) #print "--------------------------------ROAC-----------------------------------" #print df_ROAC return df_ROAC # 11ROE # 得到一个dataframe：包含股票代码、净资产收益率ROE(%)ROE和ROE_sorted_rank # 默认date = context.current_dt的前一天,使用默认值，避免未来函数，不建议修改 def get_df_ROE(stock_list, context,fdate):#, asc): # 获得净资产收益率roe df_ROE = get_fundamentals(query(indicator.code, indicator.roe ).filter(indicator.code.in_(stock_list)), date=fdate) # 删除nan df_ROE = df_ROE.dropna() # 生成排名序数 #df_ROE['ROE_sorted_rank'] = df_ROE['roe'].rank(ascending = asc, method = 'dense') # 使用股票代码作为index df_ROE.index = df_ROE.code # 删除无用数据 del df_ROE['code'] # 改个名字 df_ROE.columns = ['ROE']#, 'ROE_sorted_rank'] df_ROE=winsorize(df_ROE, scale=3, inclusive=True, inf2nan=True, axis=0) df_ROE=neutralize(df_ROE, how=['jq_l1'], date=fdate, axis=0) df_ROE=standardlize(df_ROE, inf2nan=True, axis=0) #print "--------------------------------ROE-----------------------------------" #print df_ROE return df_ROE # 12ROEC # 得到一个dataframe：包含股票代码、净资产收益率ROE变动ROE_change(ROEC)和ROEC_sorted_rank def get_df_ROEC(stock_list, context,fdate):#, asc): # 前一个交易日 yest = context.previous_date # 大约一个季度前 days_4shift_before = shift_trading_day(fdate, shift = -90) # 获得市现率roe df_ROEC = get_fundamentals(query(indicator.code, indicator.roe ).filter(indicator.code.in_(stock_list)), days_4shift_before ) # 用股票代码作为index df_ROEC.index = df_ROEC['code'] # 获取当期roe，顺序无影响，随意假设 df_ROE = get_df_ROE(stock_list, context,fdate) # ROE大写为当期值，roe小写为一个shift前的对应数据 df_ROEC['ROE'] = df_ROE['ROE'] # 计算ROE变动 df_ROEC['ROEC'] = df_ROEC['roe'] - df_ROEC['ROE'] # 删除nan df_ROEC = df_ROEC.dropna() # 生成序数序号 #df_ROEC['ROEC_sorted_rank'] = df_ROEC['ROEC'].rank(ascending = asc, method = 'dense') # 使用股票代码作为index df_ROEC.index = df_ROEC.code # 删除无用数据 del df_ROEC['code'] del df_ROEC['ROE'] del df_ROEC['roe'] df_ROEC=winsorize(df_ROEC, scale=3, inclusive=True, inf2nan=True, axis=0) df_ROEC=neutralize(df_ROEC, how=['jq_l1'], date=fdate, axis=0) df_ROEC=standardlize(df_ROEC, inf2nan=True, axis=0) #print "--------------------------------ROEC-----------------------------------" #print df_ROEC return df_ROEC # 13OPTP # 得到一个dataframe：包含股票代码、主营业务利润占比(OPTP)和OPTP_sorted_rank # 默认date = context.current_dt的前一天,使用默认值，避免未来函数，不建议修改 def get_df_OPTP(stock_list, context,fdate):#, asc): # 获得operating_profit和total_profit营业利润(元)和利润总额(元) df_OPTP = get_fundamentals(query(income.code, income.operating_profit, income.total_profit ).filter(income.code.in_(stock_list)), date=fdate) # 复制一个dataframe，按对应项目排序 df_OPTP['OPTP'] = df_OPTP['operating_profit']/df_OPTP['total_profit'] # 删除nan df_OPTP = df_OPTP.dropna() # 生成排名序数 #df_OPTP['OPTP_sorted_rank'] = df_OPTP['OPTP'].rank(ascending = asc, method = 'dense') # 使用股票代码作为index df_OPTP.index = df_OPTP.code # 删除无用数据 del df_OPTP['code'] del df_OPTP['operating_profit'] del df_OPTP['total_profit'] # 改个名字 df_OPTP.columns = ['OPTP']#, 'OPTP_sorted_rank'] df_OPTP=winsorize(df_OPTP, scale=3, inclusive=True, inf2nan=True, axis=0) df_OPTP=neutralize(df_OPTP, how=['jq_l1'], date=fdate, axis=0) df_OPTP=standardlize(df_OPTP, inf2nan=True, axis=0) #print "--------------------------------OPTP-----------------------------------" #print df_OPTP return df_OPTP # 14OPTPC def get_df_OPTPC(stock_list, context,fdate):#, asc): # 前一个交易日 yest = context.previous_date # 大约一个季度前 days_4shift_before = shift_trading_day(fdate, shift = -90) # 获得operating_profit和total_profit营业利润(元)和利润总额(元) df_OPTPC = get_fundamentals(query(income.code, income.operating_profit, income.total_profit ).filter(income.code.in_(stock_list)), days_4shift_before) df_OPTPC.index = df_OPTPC['code'] df_OPTPC = df_OPTPC.dropna() # 复制一个dataframe，按对应项目排序 df_OPTPC['optp'] = df_OPTPC['operating_profit']/df_OPTPC['total_profit'] df_OPTP = get_df_OPTP(stock_list, context,fdate) df_OPTPC['OPTP'] = df_OPTP['OPTP'] df_OPTPC['OPTPC'] = df_OPTPC['optp'] - df_OPTPC['OPTP'] df_OPTPC = df_OPTPC.dropna() # 生成排名序数 #df_OPTPC['OPTPC_sorted_rank'] = df_OPTPC['OPTPC'].rank(ascending = asc, method = 'dense') # 使用股票代码作为index df_OPTPC.index = df_OPTPC.code # 删除无用数据 del df_OPTPC['optp'] del df_OPTPC['OPTP'] del df_OPTPC['code'] del df_OPTPC['operating_profit'] del df_OPTPC['total_profit'] df_OPTPC=winsorize(df_OPTPC, scale=3, inclusive=True, inf2nan=True, axis=0) df_OPTPC=neutralize(df_OPTPC, how=['jq_l1'], date=fdate, axis=0) df_OPTPC=standardlize(df_OPTPC, inf2nan=True, axis=0) #print "--------------------------------OPTPC-----------------------------------" #print df_OPTPC return df_OPTPC # 15OPOR # 得到一个dataframe：包含股票代码、主营业务利润收入占比(OPOR)和OPOR_sorted_rank # 默认date = context.current_dt的前一天,使用默认值，避免未来函数，不建议修改 def get_df_OPOR(stock_list, context,fdate):#, asc): # 获得operating_profit和operating_revenue营业利润(元)和总营业收入(元) df_OPOR = get_fundamentals(query(income.code, income.operating_profit, income.operating_revenue ).filter(income.code.in_(stock_list)), date=fdate) # 复制一个dataframe，按对应项目排序 df_OPOR['OPOR'] = df_OPOR['operating_profit']/df_OPOR['operating_revenue'] # 删除nan df_OPOR = df_OPOR.dropna() # 生成排名序数 #df_OPOR['OPOR_sorted_rank'] = df_OPOR['OPOR'].rank(ascending = asc, method = 'dense') # 使用股票代码作为index df_OPOR.index = df_OPOR.code # 删除无用数据 del df_OPOR['code'] del df_OPOR['operating_profit'] del df_OPOR['operating_revenue'] # 改个名字 df_OPOR.columns = ['OPOR']#, 'OPOR_sorted_rank'] df_OPOR=winsorize(df_OPOR, scale=3, inclusive=True, inf2nan=True, axis=0) df_OPOR=neutralize(df_OPOR, how=['jq_l1'], date=fdate, axis=0) df_OPOR=standardlize(df_OPOR, inf2nan=True, axis=0) #df_OPOR=winsorize(df_OPOR, qrange=[0.05,0.93], inclusive=True, inf2nan=True, axis=0) #print "--------------------------------OPOR-----------------------------------" #print df_OPOR return df_OPOR ''' # 12OPOR # 得到一个dataframe：包含股票代码、主营业务利润收入占比(OPOR)和OPOR_sorted_rank # 默认date = context.current_dt的前一天,使用默认值，避免未来函数，不建议修改 def get_df_OPOR(stock_list, context,fdate): # 获得operating_profit和operating_revenue营业利润(元)和总营业收入(元) df_OPOR = get_fundamentals(query(income.code, income.operating_profit, income.operating_revenue ).filter(income.code.in_(stock_list)), date=fdate) # 复制一个dataframe，按对应项目排序 df_OPOR['OPOR'] = df_OPOR['operating_profit']/df_OPOR['operating_revenue'] # 删除nan df_OPOR = df_OPOR.dropna() #df_OPOR.index = df_OPOR.code df_OPOR = df_OPOR.drop(['operating_profit'], axis=1) df_OPOR = df_OPOR.drop(['operating_revenue'], axis=1) #df_OPTPC = df_OPTPC.reset_index(drop = True) bp_ratio = {} list_stock = [] list_value = [] industry_list = fun_get_industry(cycle=None) for industry in industry_list: tmpDict = fun_get_factor(df_OPOR, 'OPOR', industry, 2, fdate).to_dict() for stock in tmpDict.keys(): if stock in bp_ratio: if bp_ratio[stock] < tmpDict[stock]: bp_ratio[stock] = tmpDict[stock] else: bp_ratio[stock] = tmpDict[stock] #log.info(tmpDict) #df_BP1 = pd.DataFrame(tmpseries) #log.info("tmpDict % f" % (len(tmpseries))) for stock in bp_ratio.keys(): list_stock.append(stock) list_value.append(bp_ratio[stock]) df_OPOR1 = pd.DataFrame(data=list_value,index=list_stock)#,columns=BP) df_OPOR1.columns = ['OPOR'] # 生成排名序数 #df_OPOR1['OPOR_sorted_rank'] = df_OPOR1['OPOR'].rank(ascending = asc, method = 'dense') # 使用股票代码作为index #df_OPOR.index = df_OPOR.code # 删除无用数据 #del df_OPOR['code'] #del df_OPOR['operating_profit'] #del df_OPOR['operating_revenue'] # 改个名字 #df_OPOR.columns = ['OPOR', 'OPOR_sorted_rank'] print "--------------------------------OPOR-----------------------------------" print df_OPOR1 return df_OPOR1 ''' # 16OPORC def get_df_OPORC(stock_list, context,fdate):#, asc): # 前一个交易日 yest = context.previous_date # 大约一个季度前 days_4shift_before = shift_trading_day(fdate, shift = -90) # 获得operating_profit和operating_revenue营业利润(元)和总营业收入(元) df_OPORC = get_fundamentals(query(income.code, income.operating_profit, income.operating_revenue ).filter(income.code.in_(stock_list)), days_4shift_before) #df_OPORC.index = df_OPORC['code'] df_OPORC.index = df_OPORC.code df_OPORC = df_OPORC.dropna() # 复制一个dataframe，按对应项目排序 df_OPORC['opor'] = df_OPORC['operating_profit']/df_OPORC['operating_revenue'] del df_OPORC['operating_profit'] del df_OPORC['operating_revenue'] del df_OPORC['code'] df_OPORC=winsorize(df_OPORC, scale=3, inclusive=True, inf2nan=True, axis=0) df_OPOR = get_df_OPOR(stock_list, context,fdate) df_OPORC['OPOR'] = df_OPOR['OPOR'] df_OPORC['OPORC'] = df_OPORC['opor'] - df_OPORC['OPOR'] df_OPORC = df_OPORC.dropna() # 生成排名序数 #df_OPORC['OPORC_sorted_rank'] = df_OPORC['OPORC'].rank(ascending = asc, method = 'dense') # 使用股票代码作为index # 删除无用数据 del df_OPORC['opor'] del df_OPORC['OPOR'] df_OPORC=winsorize(df_OPORC, scale=3, inclusive=True, inf2nan=True, axis=0) df_OPORC=neutralize(df_OPORC, how=['jq_l1'], date=fdate, axis=0) df_OPORC=standardlize(df_OPORC, inf2nan=True, axis=0) #print "--------------------------------OPORC-----------------------------------" #print df_OPORC return df_OPORC # 17CMC # 得到一个dataframe：包含股票代码、流通市值CMC和CMC_sorted_rank # 默认date = context.current_dt的前一天,使用默认值，避免未来函数，不建议修改 def get_df_CMV(stock_list, context,fdate):#, asc): # 获得流通市值 circulating_market_cap 流通市值(亿) df_CMV = get_fundamentals(query(valuation.code, valuation.circulating_market_cap ).filter(valuation.code.in_(stock_list)), date=fdate) # 删除nan df_CMV = df_CMV.dropna() # 生成排名序数 #df_CMC['CMC_sorted_rank'] = df_CMC['circulating_market_cap'].rank(ascending = asc, method = 'dense') # 使用股票代码作为index df_CMV.index = df_CMV.code # 删除无用数据 del df_CMV['code'] # 改个名字 df_CMV.columns = ['CMV']#, 'CMC_sorted_rank'] df_CMV = df_CMV.dropna() df_CMV=winsorize(df_CMV, scale=3, inclusive=True, inf2nan=True, axis=0) #df_CMV=neutralize(df_CMV, how=['jq_l1'], date=fdate, axis=0) #df_CMV=standardlize(df_CMV, inf2nan=True, axis=0) #print "--------------------------------CMV-----------------------------------" #print df_CMV return df_CMV # 18NOPR # 得到一个dataframe：包含股票代码、收入净利率(NPOR)和NPOR_sorted_rank # 默认date = context.current_dt的前一天,使用默认值，避免未来函数，不建议修改 def get_df_NPOR(stock_list, context,fdate):#, asc): # 获得net_profit和operating_revenue净利润(元)和营业收入(元) df_NPOR = get_fundamentals(query(income.code, income.net_profit, income.operating_revenue ).filter(income.code.in_(stock_list)), date=fdate) # 复制一个dataframe，按对应项目排序 df_NPOR['NPOR'] = df_NPOR['net_profit']/df_NPOR['operating_revenue'] # 删除nan df_NPOR = df_NPOR.dropna() # 生成排名序数 #df_NPOR['NPOR_sorted_rank'] = df_NPOR['NPOR'].rank(ascending = asc, method = 'dense') # 使用股票代码作为index df_NPOR.index = df_NPOR.code # 删除无用数据 del df_NPOR['code'] del df_NPOR['net_profit'] del df_NPOR['operating_revenue'] # 改个名字 df_NPOR.columns = ['NPOR']#, 'NPOR_sorted_rank'] df_NPOR=winsorize(df_NPOR, scale=3, inclusive=True, inf2nan=True, axis=0) df_NPOR=neutralize(df_NPOR, how=['jq_l1'], date=fdate, axis=0) df_NPOR=standardlize(df_NPOR, inf2nan=True, axis=0) #print "--------------------------------NPOR-----------------------------------" #print df_NPOR return df_NPOR # 19NPORC # 得到一个dataframe：包含股票代码、收入净利率(NPORC)和NPORC_sorted_rank def get_df_NPORC(stock_list, context,fdate):#, asc): # 获得上一个交易日日期 yest = context.previous_date # 大约一个季度前 days_4shift_before = shift_trading_day(fdate, shift = -90) # 获得net_profit和operating_revenue净利润(元)和营业收入(元) df_NPORC = get_fundamentals(query(income.code, income.net_profit, income.operating_revenue ).filter(income.code.in_(stock_list)),days_4shift_before ) # 股票编号设定为index df_NPORC.index = df_NPORC['code'] # 前一期的npor df_NPORC['npor'] = df_NPORC['net_profit']/df_NPORC['operating_revenue'] # 调取NPOR当期值,默认asc=False，这里只提取npor，排序在这里没关系 df_NPOR = get_df_NPOR(stock_list, context,fdate) # 当期NPOR，需要区分大小写 df_NPORC['NPOR'] = df_NPOR['NPOR'] # 生成NPOR_change df_NPORC['NPORC'] = df_NPORC['npor'] - df_NPORC['NPOR'] # 删除nan df_NPORC = df_NPORC.dropna() # 生成排名序数 #df_NPORC['NPORC_sorted_rank'] = df_NPORC['NPORC'].rank(ascending = asc, method = 'dense') # 使用股票代码作为index df_NPORC.index = df_NPORC.code # 删除无用数据 del df_NPORC['code'] del df_NPORC['net_profit'] del df_NPORC['operating_revenue'] del df_NPORC['NPOR'] del df_NPORC['npor'] df_NPORC=winsorize(df_NPORC, scale=3, inclusive=True, inf2nan=True, axis=0) df_NPORC=neutralize(df_NPORC, how=['jq_l1'], date=fdate, axis=0) df_NPORC=standardlize(df_NPORC, inf2nan=True, axis=0) #print "--------------------------------NPORC-----------------------------------" #print df_NPORC return df_NPORC # 20MTM1 # 一个月动能，输入stock_list, context, asc = True/False # 输出：dataframe，index为code def get_df_MTM1(stock_list, context,fdate):#, asc): # 上个交易日日期 yest = shift_trading_day(fdate, shift = 0) # 一个shift前的交易日日期 days_1shift_before = shift_trading_day(fdate, shift = -21) # 获得上个交易日收盘价 df_price_info = get_price(list(stock_list), start_date=yest, end_date=yest, frequency='daily', fields='close')['close'].T # 1个月前收盘价信息 df_price_info_1shift = get_price(list(stock_list), start_date=days_1shift_before, end_date=days_1shift_before, frequency='daily', fields='close')['close'].T # 1月的收益率,Series Series_mtm1 = (df_price_info.ix[:,yest] - df_price_info_1shift.ix[:,days_1shift_before] )/df_price_info_1shift.ix[:,days_1shift_before] # 生成dataframe格式 df_MTM1 = pd.DataFrame({'MTM1':Series_mtm1}) # 删除NaN df_MTM1 = df_MTM1[pd.notnull(df_MTM1['MTM1'])] # 排序给出排序打分，MTM1 #df_MTM1['MTM1_sorted_rank'] = df_MTM1['MTM1'].rank(ascending = asc, method = 'dense') df_MTM1=winsorize(df_MTM1, scale=3, inclusive=True, inf2nan=True, axis=0) df_MTM1=neutralize(df_MTM1, how=['jq_l1'], date=fdate, axis=0) df_MTM1=standardlize(df_MTM1, inf2nan=True, axis=0) #print "--------------------------------MTM1-----------------------------------" #print df_MTM1 return df_MTM1 # 21MTM3 # 三个月动能，输入stock_list, context, asc = True/False # 输出：dataframe，index为code def get_df_MTM3(stock_list, context,fdate):#, asc): # 上个交易日日期 yest = shift_trading_day(fdate, shift = 0) # 3个shift前的交易日日期 days_3shift_before = shift_trading_day(fdate, shift = -63) # 获得上个交易日收盘价 df_price_info = get_price(list(stock_list), start_date=yest, end_date=yest, frequency='daily', fields='close')['close'].T # 1个月前收盘价信息 df_price_info_3shift = get_price(list(stock_list), start_date=days_3shift_before, end_date=days_3shift_before, frequency='daily', fields='close')['close'].T # 3个月的收益率,Series Series_mtm3 = (df_price_info.ix[:,yest] - df_price_info_3shift.ix[:,days_3shift_before] )/df_price_info_3shift.ix[:,days_3shift_before] # 生成dataframe格式 df_MTM3 = pd.DataFrame({'MTM3':Series_mtm3}) # 删除NaN df_MTM3 = df_MTM3[pd.notnull(df_MTM3['MTM3'])] # 排序给出排序打分，MTM3 #df_MTM3['MTM3_sorted_rank'] = df_MTM3['MTM3'].rank(ascending = asc, method = 'dense') df_MTM3=winsorize(df_MTM3, scale=3, inclusive=True, inf2nan=True, axis=0) df_MTM3=neutralize(df_MTM3, how=['jq_l1'], date=fdate, axis=0) df_MTM3=standardlize(df_MTM3, inf2nan=True, axis=0) #print "--------------------------------MTM3-----------------------------------" #print df_MTM3 return df_MTM3 # 22MTM6 # 六个月动能，输入stock_list, context, asc = True/False # 输出：dataframe，index为code def get_df_MTM6(stock_list, context,fdate):#, asc): # 获得上一个交易日日期 yest = shift_trading_day(fdate, shift = 0) # 一个shift前的交易日日期 days_6shift_before = shift_trading_day(fdate, shift = -125) # 获得上个交易日收盘价 df_price_info = get_price(list(stock_list), start_date=yest, end_date=yest, frequency='daily', fields='close')['close'].T # 6个月前收盘价信息 df_price_info_6shift = get_price(list(stock_list), start_date=days_6shift_before, end_date=days_6shift_before, frequency='daily', fields='close')['close'].T # MTM6六月动量,Series Series_mtm6 = (df_price_info.ix[:,yest] - df_price_info_6shift.ix[:,days_6shift_before] )/df_price_info_6shift.ix[:,days_6shift_before] # 生成dataframe格式 df_MTM6 = pd.DataFrame({'MTM6':Series_mtm6}) # 删除NaN df_MTM6 = df_MTM6[pd.notnull(df_MTM6['MTM6'])] # 排序给出排序打分，MTM6 #df_MTM6['MTM6_sorted_rank'] = df_MTM6['MTM6'].rank(ascending = asc, method = 'dense') df_MTM6=winsorize(df_MTM6, scale=3, inclusive=True, inf2nan=True, axis=0) df_MTM6=neutralize(df_MTM6, how=['jq_l1'], date=fdate, axis=0) df_MTM6=standardlize(df_MTM6, inf2nan=True, axis=0) #print "--------------------------------MTM6-----------------------------------" #print df_MTM6 return df_MTM6 # 23MTM12 # 十二个月动能，输入stock_list, context, asc = True/False # 输出：dataframe，index为code def get_df_MTM12(stock_list, context,fdate):#, asc): # 上个交易日日期 yest = shift_trading_day(fdate, shift = 0) # 一个shift前的交易日日期 days_12shift_before = shift_trading_day(fdate, shift = -250) # 获得上个交易日收盘价 df_price_info = get_price(list(stock_list), start_date=yest, end_date=yest, frequency='daily', fields='close')['close'].T # 12个月前收盘价信息 df_price_info_12shift = get_price(list(stock_list), start_date=days_12shift_before, end_date=days_12shift_before, frequency='daily', fields='close')['close'].T # MTM12月动量,Series Series_mtm12 = (df_price_info.ix[:,yest] - df_price_info_12shift.ix[:,days_12shift_before] )/df_price_info_12shift.ix[:,days_12shift_before] # 生成dataframe格式 df_MTM12 = pd.DataFrame({'MTM12':Series_mtm12}) # 删除NaN df_MTM12 = df_MTM12[pd.notnull(df_MTM12['MTM12'])] # 排序给出排序打分，MTM12 #df_MTM12['MTM12_sorted_rank'] = df_MTM12['MTM12'].rank(ascending = asc, method = 'dense') df_MTM12=winsorize(df_MTM12, scale=3, inclusive=True, inf2nan=True, axis=0) df_MTM12=neutralize(df_MTM12, how=['jq_l1'], date=fdate, axis=0) df_MTM12=standardlize(df_MTM12, inf2nan=True, axis=0) #print "--------------------------------MTM12-----------------------------------" #print df_MTM12 return df_MTM12 # 24TR # 得到一个dataframe：包含股票代码、换手率(%)TR和TR_sorted_rank # 默认date = context.previous_date,使用默认值，避免未来函数，不建议修改 def get_df_TR(stock_list, context,fdate):#, asc): # 获取价格数据,当前到21天前一共22行，与之前get_price不同，没有使用转置，行为股票代码 # 列为日期，上边为较早最后为较晚 df_volume_info_between_1shift = get_price(list(stock_list), count = 22, end_date = fdate, frequency = 'daily', fields = 'volume')['volume'].T # 换手量加总 df_volume_info_between_1shift['VOLUME'] = df_volume_info_between_1shift.sum(axis=1,skipna=True) # 获得换手率(%)turnover_ratio df_TR = get_fundamentals(query(valuation.code, valuation.circulating_cap ).filter(valuation.code.in_(stock_list)), date=fdate) # 删除nan df_TR = df_TR.dropna() # 使用股

@薛定谔の喵 how=['jq_l1', 'market_cap'] 时，运行没有问题，当how=['jq_l2', 'market_cap'] 时，运行到20181201的时候就出错 2018-06-01 09:30:00 - INFO - time 2012-01-01 2018-06-01 09:30:00 - INFO - time 2012-02-01 2018-06-01 09:30:00 - INFO - time 2012-03-01 2018-06-01 09:30:00 - INFO - time 2012-04-01 2018-06-01 09:30:00 - INFO - time 2012-05-01 2018-06-01 09:30:00 - INFO - time 2012-06-01 2018-06-01 09:30:00 - INFO - time 2012-07-01 2018-06-01 09:30:00 - INFO - time 2012-08-01 2018-06-01 09:30:00 - INFO - time 2012-09-01 2018-06-01 09:30:00 - INFO - time 2012-10-01 2018-06-01 09:30:00 - INFO - time 2012-11-01 2018-06-01 09:30:00 - ERROR - Traceback (most recent call last): File "jqboson/core/entry.py", line 373, in _run engine.start() File "jqboson/core/engine.py", line 240, in start self._dispatcher.start() File "jqboson/core/dispatcher.py", line 209, in start self._loop() File "jqboson/core/dispatcher.py", line 189, in _loop self._event_bus.emit(ev[1]) File "jqboson/core/bus.py", line 35, in emit ret.append(call(event)) File "jqboson/core/strategy.py", line 251, in _wrapper return cb(self._context.strategy_environment.strategy_context) File "/tmp/strategy/user_code.py", line 64, in fun_main fdf = get_factors(g.feasible_stocks, context, g.factors,startdate) File "/tmp/strategy/user_code.py", line 379, in get_factors aa = globals()[tmp](stocks_list,context,fdate)#,value) File "/tmp/strategy/user_code.py", line 593, in get_df_PS df_PS=neutralize(df_PS, how=['jq_l2', 'market_cap'], date=fdate, axis=0) File "jqfactor/__init__.py", line 295, in neutralize return neutralize(data, how=how, date=date, axis=axis) File "jqfactor/preprocess.py", line 229, in neutralize classified_fields=filter_factors([factor]), File "jqfactor/calculate.py", line 488, in _get_basic_factor_data industry_data = self._get_industry_data(securities, dates, industries) File "jqfactor/calculate.py", line 303, in _get_industry_data sec_codes = self.idst_store.get_security_industry_date(securities, industries) File "jqdata/stores/industry_store.py", line 162, in get_security_industry_date IndustryEntity.stock.in_(stock_list)).filter(IndustryEntity.code.in_(industries)).distinct().all() File "sqlalchemy/orm/query.py", line 2399, in all return list(self) File "sqlalchemy/orm/query.py", line 2516, in __iter__ return self._execute_and_instances(context) File "sqlalchemy/orm/query.py", line 2531, in _execute_and_instances result = conn.execute(querycontext.statement, self._params) File "sqlalchemy/engine/base.py", line 914, in execute return meth(self, multiparams, params) File "sqlalchemy/sql/elements.py", line 323, in _execute_on_connection return connection._execute_clauseelement(self, multiparams, params) File "sqlalchemy/engine/base.py", line 1010, in _execute_clauseelement compiled_sql, distilled_params File "sqlalchemy/engine/base.py", line 1146, in _execute_context context) File "sqlalchemy/engine/base.py", line 1341, in _handle_dbapi_exception exc_info File "sqlalchemy/util/compat.py", line 199, in raise_from_cause reraise(type(exception), exception, tb=exc_tb) File "sqlalchemy/engine/base.py", line 1139, in _execute_context context) File "sqlalchemy/engine/default.py", line 450, in do_execute cursor.execute(statement, parameters) OperationalError: (sqlite3.OperationalError) too many SQL variables [SQL: u'SELECT DISTINCT industry.stock AS industry_stock, industry.code AS industry_code, industry.stock_startdate AS industry_stock_startdate, industry.stock_enddate AS industry_stock_enddate \nFROM industry \nWHERE industry.stock IN (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) AND industry.code IN (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)'] [parameters: ('600000.XSHG', '600004.XSHG', '600006.XSHG', '600007.XSHG', '600008.XSHG', '600009.XSHG', '600010.XSHG', '600011.XSHG', '600012.XSHG', '600015.XSHG', '600016.XSHG', '600017.XSHG', '600018.XSHG', '600019.XSHG', '600021.XSHG', '600022.XSHG', '600026.XSHG', '600027.XSHG', '600028.XSHG', '600029.XSHG', '600030.XSHG', '600031.XSHG', '600033.XSHG', '600035.XSHG', '600036.XSHG', '600037.XSHG', '600038.XSHG', '600039.XSHG', '600048.XSHG', '600050.XSHG', '600051.XSHG', '600052.XSHG', '600053.XSHG', '600054.XSHG', '600055.XSHG', '600056.XSHG', '600057.XSHG', '600058.XSHG', '600059.XSHG', '600060.XSHG', '600061.XSHG', '600062.XSHG', '600064.XSHG', '600066.XSHG', '600067.XSHG', '600068.XSHG', '600069.XSHG', '600070.XSHG', '600071.XSHG', '600072.XSHG', '600073.XSHG', '600075.XSHG', '600076.XSHG', '600077.XSHG', '600078.XSHG', '600079.XSHG', '600080.XSHG', '600081.XSHG', '600082.XSHG', '600084.XSHG', '600085.XSHG', '600086.XSHG', '600088.XSHG', '600089.XSHG', '600090.XSHG', '600091.XSHG', '600093.XSHG', '600094.XSHG', '600095.XSHG', '600096.XSHG', '600097.XSHG', '600098.XSHG', '600099.XSHG', '600100.XSHG', '600101.XSHG', '600103.XSHG', '600104.XSHG', '600105.XSHG', '600106.XSHG', '600107.XSHG', '600108.XSHG', '600109.XSHG', '600110.XSHG', '600111.XSHG', '600112.XSHG', '600113.XSHG', '600114.XSHG', '600115.XSHG', '600116.XSHG', '600117.XSHG', '600118.XSHG', '600119.XSHG', '600120.XSHG', '600122.XSHG', '600123.XSHG', '600125.XSHG', '600126.XSHG', '600127.XSHG', '600128.XSHG', '600129.XSHG', '600130.XSHG', '600131.XSHG', '600132.XSHG', '600133.XSHG', '600135.XSHG', '600136.XSHG', '600137.XSHG', '600138.XSHG', '600139.XSHG', '600141.XSHG', '600143.XSHG', '600145.XSHG', '600148.XSHG', '600149.XSHG', '600150.XSHG', '600152.XSHG', '600153.XSHG', '600155.XSHG', '600156.XSHG', '600157.XSHG', '600158.XSHG', '600159.XSHG', '600160.XSHG', '600161.XSHG', '600162.XSHG', '600163.XSHG', '600165.XSHG', '600166.XSHG', '600167.XSHG', '600168.XSHG', '600169.XSHG', '600170.XSHG', '600171.XSHG', '600172.XSHG', '600173.XSHG', '600175.XSHG', '600176.XSHG', '600177.XSHG', '600178.XSHG', '600180.XSHG', '600182.XSHG', '600183.XSHG', '600184.XSHG', '600185.XSHG', '600186.XSHG', '600187.XSHG', '600188.XSHG', '600189.XSHG', '600190.XSHG', '600192.XSHG', '600193.XSHG', '600195.XSHG', '600196.XSHG', '600197.XSHG', '600198.XSHG', '600199.XSHG', '600200.XSHG', '600201.XSHG', '600202.XSHG', '600203.XSHG', '600206.XSHG', '600207.XSHG', '600208.XSHG', '600209.XSHG', '600210.XSHG', '600211.XSHG', '600212.XSHG', '600213.XSHG', '600215.XSHG', '600216.XSHG', '600217.XSHG', '600218.XSHG', '600219.XSHG', '600220.XSHG', '600221.XSHG', '600222.XSHG', '600223.XSHG', '600226.XSHG', '600227.XSHG', '600228.XSHG', '600229.XSHG', '600230.XSHG', '600231.XSHG', '600232.XSHG', '600233.XSHG', '600234.XSHG', '600235.XSHG', '600236.XSHG', '600237.XSHG', '600238.XSHG', '600239.XSHG', '600240.XSHG', '600241.XSHG', '600242.XSHG', '600243.XSHG', '600246.XSHG', '600247.XSHG', '600248.XSHG', '600249.XSHG', '600250.XSHG', '600251.XSHG', '600252.XSHG', '600255.XSHG', '600256.XSHG', '600257.XSHG', '600258.XSHG', '600259.XSHG', '600260.XSHG', '600261.XSHG', '600262.XSHG', '600265.XSHG', '600266.XSHG', '600267.XSHG', '600268.XSHG', '600269.XSHG', '600270.XSHG', '600271.XSHG', '600272.XSHG', '600275.XSHG', '600276.XSHG', '600277.XSHG', '600278.XSHG', '600279.XSHG', '600280.XSHG', '600281.XSHG', '600282.XSHG', '600283.XSHG', '600284.XSHG', '600285.XSHG', '600288.XSHG', '600289.XSHG', '600291.XSHG', '600292.XSHG', '600293.XSHG', '600297.XSHG', '600298.XSHG', '600300.XSHG', '600302.XSHG', '600303.XSHG', '600305.XSHG', '600306.XSHG', '600307.XSHG', '600308.XSHG', '600309.XSHG', '600310.XSHG', '600311.XSHG', '600313.XSHG', '600315.XSHG', '600316.XSHG', '600317.XSHG', '600318.XSHG', '600319.XSHG', '600320.XSHG', '600321.XSHG', '600322.XSHG', '600323.XSHG', '600325.XSHG', '600326.XSHG', '600327.XSHG', '600328.XSHG', '600329.XSHG', '600330.XSHG', '600331.XSHG', '600332.XSHG', '600333.XSHG', '600335.XSHG', '600336.XSHG', '600337.XSHG', '600339.XSHG', '600340.XSHG', '600343.XSHG', '600345.XSHG', '600346.XSHG', '600348.XSHG', '600350.XSHG', '600351.XSHG', '600352.XSHG', '600353.XSHG', '600354.XSHG', '600355.XSHG', '600356.XSHG', '600360.XSHG', '600361.XSHG', '600362.XSHG', '600363.XSHG', '600365.XSHG', '600366.XSHG', '600367.XSHG', '600368.XSHG', '600369.XSHG', '600370.XSHG', '600371.XSHG', '600372.XSHG', '600373.XSHG', '600376.XSHG', '600377.XSHG', '600378.XSHG', '600379.XSHG', '600380.XSHG', '600381.XSHG', '600382.XSHG', '600383.XSHG', '600385.XSHG', '600386.XSHG', '600387.XSHG', '600388.XSHG', '600389.XSHG', '600390.XSHG', '600391.XSHG', '600392.XSHG', '600393.XSHG', '600395.XSHG', '600396.XSHG', '600397.XSHG', '600398.XSHG', '600399.XSHG', '600400.XSHG', '600401.XSHG', '600403.XSHG', '600405.XSHG', '600408.XSHG', '600409.XSHG', '600410.XSHG', '600415.XSHG', '600416.XSHG', '600418.XSHG', '600419.XSHG', '600420.XSHG', '600421.XSHG', '600422.XSHG', '600423.XSHG', '600425.XSHG', '600426.XSHG', '600428.XSHG', '600429.XSHG', '600432.XSHG', '600435.XSHG', '600436.XSHG', '600438.XSHG', '600439.XSHG', '600444.XSHG', '600446.XSHG', '600448.XSHG', '600449.XSHG', '600452.XSHG', '600455.XSHG', '600456.XSHG', '600458.XSHG', '600459.XSHG', '600460.XSHG', '600461.XSHG', '600463.XSHG', '600466.XSHG', '600467.XSHG', '600468.XSHG', '600469.XSHG', '600470.XSHG', '600475.XSHG', '600476.XSHG', '600477.XSHG', '600478.XSHG', '600479.XSHG', '600480.XSHG', '600481.XSHG', '600482.XSHG', '600483.XSHG', '600485.XSHG', '600486.XSHG', '600487.XSHG', '600488.XSHG', '600489.XSHG', '600490.XSHG', '600491.XSHG', '600493.XSHG', '600495.XSHG', '600496.XSHG', '600497.XSHG', '600498.XSHG', '600499.XSHG', '600500.XSHG', '600501.XSHG', '600502.XSHG', '600503.XSHG', '600505.XSHG', '600506.XSHG', '600507.XSHG', '600508.XSHG', '600509.XSHG', '600510.XSHG', '600511.XSHG', '600512.XSHG', '600513.XSHG', '600515.XSHG', '600516.XSHG', '600517.XSHG', '600518.XSHG', '600519.XSHG', '600521.XSHG', '600522.XSHG', '600523.XSHG', '600525.XSHG', '600526.XSHG', '600527.XSHG', '600528.XSHG', '600529.XSHG', '600530.XSHG', '600531.XSHG', '600532.XSHG', '600533.XSHG', '600535.XSHG', '600536.XSHG', '600537.XSHG', '600538.XSHG', '600539.XSHG', '600540.XSHG', '600543.XSHG', '600545.XSHG', '600546.XSHG', '600547.XSHG', '600548.XSHG', '600549.XSHG', '600550.XSHG', '600551.XSHG', '600552.XSHG', '600555.XSHG', '600557.XSHG', '600558.XSHG', '600559.XSHG', '600560.XSHG', '600561.XSHG', '600563.XSHG', '600565.XSHG', '600566.XSHG', '600568.XSHG', '600569.XSHG', '600570.XSHG', '600571.XSHG', '600572.XSHG', '600573.XSHG', '600575.XSHG', '600576.XSHG', '600580.XSHG', '600581.XSHG', '600582.XSHG', '600584.XSHG', '600585.XSHG', '600586.XSHG', '600587.XSHG', '600588.XSHG', '600589.XSHG', '600590.XSHG', '600592.XSHG', '600593.XSHG', '600594.XSHG', '600595.XSHG', '600597.XSHG', '600598.XSHG', '600599.XSHG', '600600.XSHG', '600601.XSHG', '600602.XSHG', '600603.XSHG', '600604.XSHG', '600605.XSHG', '600606.XSHG', '600608.XSHG', '600609.XSHG', '600610.XSHG', '600611.XSHG', '600612.XSHG', '600613.XSHG', '600614.XSHG', '600615.XSHG', '600616.XSHG', '600617.XSHG', '600618.XSHG', '600619.XSHG', '600620.XSHG', '600621.XSHG', '600622.XSHG', '600623.XSHG', '600624.XSHG', '600626.XSHG', '600628.XSHG', '600629.XSHG', '600630.XSHG', '600633.XSHG', '600634.XSHG', '600635.XSHG', '600636.XSHG', '600637.XSHG', '600638.XSHG', '600639.XSHG', '600640.XSHG', '600641.XSHG', '600642.XSHG', '600643.XSHG', '600644.XSHG', '600645.XSHG', '600647.XSHG', '600649.XSHG', '600650.XSHG', '600651.XSHG', '600652.XSHG', '600653.XSHG', '600654.XSHG', '600655.XSHG', '600657.XSHG', '600658.XSHG', '600660.XSHG', '600661.XSHG', '600662.XSHG', '600663.XSHG', '600664.XSHG', '600665.XSHG', '600666.XSHG', '600668.XSHG', '600671.XSHG', '600673.XSHG', '600675.XSHG', '600676.XSHG', '600677.XSHG', '600679.XSHG', '600680.XSHG', '600681.XSHG', '600682.XSHG', '600683.XSHG', '600685.XSHG', '600686.XSHG', '600687.XSHG', '600688.XSHG', '600690.XSHG', '600691.XSHG', '600692.XSHG', '600693.XSHG', '600694.XSHG', '600695.XSHG', '600696.XSHG', '600697.XSHG', '600701.XSHG', '600702.XSHG', '600703.XSHG', '600704.XSHG', '600705.XSHG', '600706.XSHG', '600707.XSHG', '600708.XSHG', '600710.XSHG', '600711.XSHG', '600712.XSHG', '600713.XSHG', '600714.XSHG', '600715.XSHG', '600716.XSHG', '600717.XSHG', '600718.XSHG', '600719.XSHG', '600720.XSHG', '600721.XSHG', '600723.XSHG', '600724.XSHG', '600725.XSHG', '600726.XSHG', '600727.XSHG', '600728.XSHG', '600729.XSHG', '600730.XSHG', '600731.XSHG', '600732.XSHG', '600733.XSHG', '600734.XSHG', '600735.XSHG', '600736.XSHG', '600737.XSHG', '600738.XSHG', '600739.XSHG', '600740.XSHG', '600741.XSHG', '600742.XSHG', '600743.XSHG', '600744.XSHG', '600746.XSHG', '600748.XSHG', '600749.XSHG', '600750.XSHG', '600751.XSHG', '600753.XSHG', '600754.XSHG', '600755.XSHG', '600756.XSHG', '600757.XSHG', '600758.XSHG', '600759.XSHG', '600760.XSHG', '600761.XSHG', '600763.XSHG', '600764.XSHG', '600765.XSHG', '600766.XSHG', '600767.XSHG', '600768.XSHG', '600769.XSHG', '600770.XSHG', '600773.XSHG', '600774.XSHG', '600775.XSHG', '600776.XSHG', '600777.XSHG', '600778.XSHG', '600779.XSHG', '600781.XSHG', '600782.XSHG', '600783.XSHG', '600785.XSHG', '600787.XSHG', '600789.XSHG', '600790.XSHG', '600791.XSHG', '600792.XSHG', '600793.XSHG', '600794.XSHG', '600796.XSHG', '600797.XSHG', '600801.XSHG', '600802.XSHG', '600803.XSHG', '600804.XSHG', '600805.XSHG', '600806.XSHG', '600808.XSHG', '600809.XSHG', '600810.XSHG', '600811.XSHG', '600812.XSHG', '600815.XSHG', '600816.XSHG', '600818.XSHG', '600819.XSHG', '600820.XSHG', '600821.XSHG', '600822.XSHG', '600823.XSHG', '600824.XSHG', '600825.XSHG', '600826.XSHG', '600827.XSHG', '600828.XSHG', '600829.XSHG', '600830.XSHG', '600831.XSHG', '600833.XSHG', '600834.XSHG', '600835.XSHG', '600836.XSHG', '600837.XSHG', '600838.XSHG', '600839.XSHG', '600841.XSHG', '600843.XSHG', '600844.XSHG', '600845.XSHG', '600846.XSHG', '600847.XSHG', '600848.XSHG', '600850.XSHG', '600851.XSHG', '600853.XSHG', '600854.XSHG', '600855.XSHG', '600856.XSHG', '600857.XSHG', '600858.XSHG', '600859.XSHG', '600860.XSHG', '600861.XSHG', '600862.XSHG', '600863.XSHG', '600864.XSHG', '600865.XSHG', '600866.XSHG', '600867.XSHG', '600868.XSHG', '600870.XSHG', '600871.XSHG', '600872.XSHG', '600873.XSHG', '600874.XSHG', '600875.XSHG', '600876.XSHG', '600877.XSHG', '600879.XSHG', '600881.XSHG', '600882.XSHG', '600883.XSHG', '600884.XSHG', '600885.XSHG', '600886.XSHG', '600887.XSHG', '600888.XSHG', '600889.XSHG', '600890.XSHG', '600891.XSHG', '600892.XSHG', '600893.XSHG', '600894.XSHG', '600895.XSHG', '600896.XSHG', '600897.XSHG', '600898.XSHG', '600900.XSHG', '600960.XSHG', '600961.XSHG', '600962.XSHG', '600963.XSHG', '600965.XSHG', '600966.XSHG', '600967.XSHG', '600969.XSHG', '600970.XSHG', '600971.XSHG', '600973.XSHG', '600975.XSHG', '600976.XSHG', '600978.XSHG', '600979.XSHG', '600980.XSHG', '600981.XSHG', '600982.XSHG', '600983.XSHG', '600984.XSHG', '600986.XSHG', '600987.XSHG', '600988.XSHG', '600990.XSHG', '600992.XSHG', '600993.XSHG', '600995.XSHG', '600997.XSHG', '600998.XSHG', '600999.XSHG', '601000.XSHG', '601001.XSHG', '601002.XSHG', '601003.XSHG', '601005.XSHG', '601006.XSHG', '601007.XSHG', '601008.XSHG', '601009.XSHG', '601010.XSHG', '601011.XSHG', '601012.XSHG', '601018.XSHG', '601028.XSHG', '601058.XSHG', '601088.XSHG', '601098.XSHG', '601099.XSHG', '601100.XSHG', '601106.XSHG', '601107.XSHG', '601113.XSHG', '601116.XSHG', '601117.XSHG', '601118.XSHG', '601126.XSHG', '601137.XSHG', '601139.XSHG', '601158.XSHG', '601166.XSHG', '601168.XSHG', '601169.XSHG', '601177.XSHG', '601179.XSHG', '601186.XSHG', '601188.XSHG', '601199.XSHG', '601208.XSHG', '601216.XSHG', '601218.XSHG', '601222.XSHG', '601231.XSHG', '601233.XSHG', '601238.XSHG', '601258.XSHG', '601288.XSHG', '601311.XSHG', '601318.XSHG', '601328.XSHG', '601333.XSHG', '601336.XSHG', '601339.XSHG', '601360.XSHG', '601369.XSHG', '601377.XSHG', '601388.XSHG', '601390.XSHG', '601398.XSHG', '601515.XSHG', '601518.XSHG', '601519.XSHG', '601555.XSHG', '601558.XSHG', '601566.XSHG', '601567.XSHG', '601588.XSHG', '601599.XSHG', '601600.XSHG', '601601.XSHG', '601607.XSHG', '601608.XSHG', '601616.XSHG', '601618.XSHG', '601628.XSHG', '601633.XSHG', '601636.XSHG', '601666.XSHG', '601668.XSHG', '601669.XSHG', '601677.XSHG', '601678.XSHG', '601688.XSHG', '601699.XSHG', '601700.XSHG', '601717.XSHG', '601718.XSHG', '601727.XSHG', '601766.XSHG', '601777.XSHG', '601788.XSHG', '601789.XSHG', '601798.XSHG', '601799.XSHG', '601800.XSHG', '601801.XSHG', '601808.XSHG', '601818.XSHG', '601857.XSHG', '601866.XSHG', '601872.XSHG', '601877.XSHG', '601880.XSHG', '601886.XSHG', '601888.XSHG', '601890.XSHG', '601898.XSHG', '601899.XSHG', '601901.XSHG', '601908.XSHG', '601918.XSHG', '601919.XSHG', '601928.XSHG', '601929.XSHG', '601933.XSHG', '601939.XSHG', '601958.XSHG', '601965.XSHG', '601988.XSHG', '601989.XSHG', '601991.XSHG', '601992.XSHG', '601996.XSHG', '601998.XSHG', '601999.XSHG', '603000.XSHG', '603001.XSHG', '603002.XSHG', '603008.XSHG', '603077.XSHG', '603123.XSHG', '603128.XSHG', '603333.XSHG', '603366.XSHG', u'HY530', u'HY531', u'HY578', u'HY470', u'HY483', u'HY480', u'HY481', u'HY486', u'HY487', u'HY484', u'HY485', u'HY488', u'HY489', u'HY588', u'HY570', u'HY501', u'HY500', u'HY506', u'HY505', u'HY504', u'HY509', u'HY527', u'HY510', u'HY437', u'HY436', u'HY435', u'HY434', u'HY433', u'HY432', u'HY439', u'HY438', u'HY455', u'HY454', u'HY457', u'HY518', u'HY519', u'HY453', u'HY452', u'HY514', u'HY515', u'HY516', u'HY517', u'HY459', u'HY511', u'HY512', u'HY513', u'HY526', u'HY420', u'HY421', u'HY422', u'HY423', u'HY424', u'HY425', u'HY426', u'HY427', u'HY428', u'HY429', u'HY587', u'HY446', u'HY447', u'HY444', u'HY445', u'HY442', u'HY443', u'HY440', u'HY441', u'HY406', u'HY407', u'HY448', u'HY449', u'HY595', u'HY596', u'HY597', u'HY591', u'HY593', u'HY598', u'HY458', u'HY473', u'HY472', u'HY471', u'HY579', u'HY477', u'HY476', u'HY474', u'HY572', u'HY573', u'HY479', u'HY478', u'HY576', u'HY574', u'HY451', u'HY450', u'HY468', u'HY469', u'HY464', u'HY465', u'HY466', u'HY467', u'HY460', u'HY461', u'HY462', u'HY463', u'HY571', u'HY601', u'HY419', u'HY418', u'HY411', u'HY410', u'HY413', u'HY412', u'HY415', u'HY414', u'HY417', u'HY416', u'HY525', u'HY524', u'HY408', u'HY409', u'HY521', u'HY520', u'HY523', u'HY402', u'HY403', u'HY401', u'HY529', u'HY528', u'HY404', u'HY405', u'HY491', u'HY493', u'HY492', u'HY494', u'HY497', u'HY496')]

大哥....我错了! T_T ,您还是在研究中建个类似策略中传入的dataframe测试一下正常不,您这么多代码,我复制过来排版都需要好长时间

@薛定谔の喵 哈哈，研究中运行经常会没反应了，没办法

@Terrywu 把您研究中的代码给我

@薛定谔の喵 有没有qq或者邮箱，我发你，帮我试一下可以吗，真的是用聚宽1就正常，用聚宽2级行业，到2012-12-01就出错 刚又试了一次，聚宽1级行业的，就正常 2018-06-01 09:30:00 - INFO - time 2012-01-01 2018-06-01 09:30:00 - INFO - time 2012-02-01 2018-06-01 09:30:00 - INFO - time 2012-03-01 2018-06-01 09:30:00 - INFO - time 2012-04-01 2018-06-01 09:30:00 - INFO - time 2012-05-01 2018-06-01 09:30:00 - INFO - time 2012-06-01 2018-06-01 09:30:00 - INFO - time 2012-07-01 2018-06-01 09:30:00 - INFO - time 2012-08-01 2018-06-01 09:30:00 - INFO - time 2012-09-01 2018-06-01 09:30:00 - INFO - time 2012-10-01 2018-06-01 09:30:00 - INFO - time 2012-11-01 2018-06-01 09:30:00 - INFO - time 2012-12-01 2018-06-01 09:30:00 - INFO - time 2013-01-01 正在加载日志...

@薛定谔の喵 研究里之前运行经常卡着没反应了，就都在策略里试了，研究里的是老的没修改过的，最好还是帮我试一下策略里的吧，我把代码发你邮箱也可以，可以吗？

@Terrywu 1147945735@qq.com