周期转换函数
# 周期转换函数
def data_cycle_change(df, rule_type = '5T'):
'''
周期转换,盘前数据转换可以直接用这个接口处理
1分钟转换其他分钟:
'5m':rule_type = '5T', '15m':rule_type = '15T', '30m':rule_type = '30T',
'60m':rule_type = '60T'
日线转换周线:
'1W':rule_type = '1W'
'1M':rule_type = '1m'
'''
# df['low'] = df['low'].resample(rule = rule_type, base = 0,label = 'right', closed = 'right').min()
# df['high'] = df['high'].resample(rule = rule_type, base = 0,label = 'right', closed = 'right').max()
# df['open'] = df['open'].resample(rule = rule_type, base = 0,label = 'right', closed = 'right').first()
# df['close'] = df['close'].resample(rule = rule_type, base = 0,label = 'right', closed = 'right').last()
# df['volume'] = df['volume'].resample(rule = rule_type, base = 0,label = 'right', closed = 'right').sum()
df.dropna(inplace=True)
return df
全部 0条评论