[已解决]悬赏求助解决处理的不同变量的问题

jensonl

1. def init(context):
   
2. subscribe(symbols=symbol, frequency='tick')

复制代码

上面是我订阅了一组数据。  
其中 symbol 里面我打包了很多个字符串列表。   

然后这个subscribe() 会每秒传给我，每个字符串对应的数据组。
其中symbol:SHSE.600618  这个是一个标签。   当然也有 symbol:SHSE.600000 ， symbol: SHSE.600001 等等等等

1. {'symbol': 'SHSE.600618', 'created_at': datetime.datetime(2018, 2, 23, 10, 1, 8, 770000), 'price': 10.350000381469727, 'open': 10.34000015258789, 'high': 10.359999656677246, 'low': 10.279999732971191, 'cum_volume': 547813.0, 'cum_amount': 5653861.0, 'cum_position': 0, 'last_amount': 87975.0, 'last_volume': 8500, 'trade_type': 7, 'nanos': 770000000, 'quotes': [{'bid_p': 10.350000381469727, 'bid_v': 7000, 'ask_p': 10.359999656677246, 'ask_v': 14500}, {'bid_p': 10.34000015258789, 'bid_v': 18000, 'ask_p': 10.369999885559082, 'ask_v': 2000}, {'bid_p': 10.329999923706055, 'bid_v': 1500, 'ask_p': 10.380000114440918, 'ask_v': 9300}, {'bid_p': 10.319999694824219, 'bid_v': 9200, 'ask_p': 10.390000343322754, 'ask_v': 22100}, {'bid_p': 10.3100004196167, 'bid_v': 23100, 'ask_p': 10.399999618530273, 'ask_v': 56600}]}
   

复制代码

1. {'symbol': 'SHSE.600000', 'created_at': datetime.datetime(2018, 2, 23, 10, 1, 8, 770000), 'price': 10.350000381469727, 'open': 10.34000015258789, 'high': 10.359999656677246, 'low': 10.279999732971191, 'cum_volume': 547813.0, 'cum_amount': 5653861.0, 'cum_position': 0, 'last_amount': 87975.0, 'last_volume': 8500, 'trade_type': 7, 'nanos': 770000000, 'quotes': [{'bid_p': 10.350000381469727, 'bid_v': 7000, 'ask_p': 10.359999656677246, 'ask_v': 14500}, {'bid_p': 10.34000015258789, 'bid_v': 18000, 'ask_p': 10.369999885559082, 'ask_v': 2000}, {'bid_p': 10.329999923706055, 'bid_v': 1500, 'ask_p': 10.380000114440918, 'ask_v': 9300}, {'bid_p': 10.319999694824219, 'bid_v': 9200, 'ask_p': 10.390000343322754, 'ask_v': 22100}, {'bid_p': 10.3100004196167, 'bid_v': 23100, 'ask_p': 10.399999618530273, 'ask_v': 56600}]}

复制代码

然后我目前处理的是:
建立全局变量

s600618 = []
s600000 = []
s600001 = []

1. 
   
2. if symb == 'SHSE.600618'  :
   
3.       s600618.append(float('%.2f' % tick['price']))
   
4.       g = Up_grade(s600618)
   
5.         rate = g.rate()
   
6.         vol = int(tick['last_volume']/100)
   
7.         result = stock_dict[symb]
   
8.         if len(s600618)> 3:
   
9.             sale_price =s600618[-1]
   
10.            xxxxxxxxxxxxxxxxxxx
    
11. 
    
12. if symb == 'SHSE.600000':
    
13.      s600000.append(float('%.2f' % tick['price']))
    
14.      g = Up_grade(s600000)
    
15.         rate = g.rate()
    
16.         vol = int(tick['last_volume']/100)
    
17.         result = stock_dict[symb]
    
18.         if len(s600000)> 3:
    
19.             sale_price =s600000[-1]
    
20.            xxxxxxxxxxxxxxx
    
21. 
    
22. if symb == 'SHSE.600001':
    
23.      s600001.append(float('%.2f' % tick['price']))
    
24.     g = Up_grade(s600001)
    
25.         rate = g.rate()
    
26.         vol = int(tick['last_volume']/100)
    
27.         result = stock_dict[symb]
    
28.         if len(s600001)> 3:
    
29.             sale_price =s600001[-1]
    
30.             xxxxxxxxxxxxxxxxxxxxxx

复制代码

来处理 不同的SHSE.xxxxx 的数据。
我建立了一个Up_grade的类，来运行相同的策略。 但这样代码修正起来还是非常麻烦，

一旦有些变动，需要一个一个去修改里面的内容。

我曾经想用用  locals()[tick['symbol']] 来代替变量。
但是每个不同的变量还要生成一个 list的列表 来存放数据。 然后进行处理

请问有什么办法可以解决 这个问题。

谢谢。

最佳答案

月排行榜 / 总排行榜

chakyam

2018-3-2 15:29:55

不知道有没有理解对楼主的意思

楼主是想对subscribe()传回来的数据进行整理，因为subscribe()传回来的数据多种多样，有SHSE.600000，SHSE.600001，SHSE.600002，SHSE.600003，SHSE.600004等等许多不同的symbol名，而现在楼主是想写一个通用的处理过程，可以实现对上述的各种symbol名的数据的处理 ？

另外s600618.append(float('%.2f' % tick['price']))
这里的tick是下面这段东西吗？

1. {'symbol': 'SHSE.600618', 'created_at': datetime.datetime(2018, 2, 23, 10, 1, 8, 770000), 'price': 10.350000381469727, 'open': 10.34000015258789, 'high': 10.359999656677246, 'low': 10.279999732971191, 'cum_volume': 547813.0, 'cum_amount': 5653861.0, 'cum_position': 0, 'last_amount': 87975.0, 'last_volume': 8500, 'trade_type': 7, 'nanos': 770000000, 'quotes': [{'bid_p': 10.350000381469727, 'bid_v': 7000, 'ask_p': 10.359999656677246, 'ask_v': 14500}, {'bid_p': 10.34000015258789, 'bid_v': 18000, 'ask_p': 10.369999885559082, 'ask_v': 2000}, {'bid_p': 10.329999923706055, 'bid_v': 1500, 'ask_p': 10.380000114440918, 'ask_v': 9300}, {'bid_p': 10.319999694824219, 'bid_v': 9200, 'ask_p': 10.390000343322754, 'ask_v': 22100}, {'bid_p': 10.3100004196167, 'bid_v': 23100, 'ask_p': 10.399999618530273, 'ask_v': 56600}]}
   

复制代码

跳转到最佳答案楼层

chakyam

不知道有没有理解对楼主的意思

楼主是想对subscribe()传回来的数据进行整理，因为subscribe()传回来的数据多种多样，有SHSE.600000，SHSE.600001，SHSE.600002，SHSE.600003，SHSE.600004等等许多不同的symbol名，而现在楼主是想写一个通用的处理过程，可以实现对上述的各种symbol名的数据的处理 ？

另外s600618.append(float('%.2f' % tick['price']))
这里的tick是下面这段东西吗？

1. {'symbol': 'SHSE.600618', 'created_at': datetime.datetime(2018, 2, 23, 10, 1, 8, 770000), 'price': 10.350000381469727, 'open': 10.34000015258789, 'high': 10.359999656677246, 'low': 10.279999732971191, 'cum_volume': 547813.0, 'cum_amount': 5653861.0, 'cum_position': 0, 'last_amount': 87975.0, 'last_volume': 8500, 'trade_type': 7, 'nanos': 770000000, 'quotes': [{'bid_p': 10.350000381469727, 'bid_v': 7000, 'ask_p': 10.359999656677246, 'ask_v': 14500}, {'bid_p': 10.34000015258789, 'bid_v': 18000, 'ask_p': 10.369999885559082, 'ask_v': 2000}, {'bid_p': 10.329999923706055, 'bid_v': 1500, 'ask_p': 10.380000114440918, 'ask_v': 9300}, {'bid_p': 10.319999694824219, 'bid_v': 9200, 'ask_p': 10.390000343322754, 'ask_v': 22100}, {'bid_p': 10.3100004196167, 'bid_v': 23100, 'ask_p': 10.399999618530273, 'ask_v': 56600}]}
   

复制代码

jensonl

  谁能指教下吗。最好可以附上代码

jensonl

为啥就我的问题没人解答。 是太难了吗。。。

waitforlove

真是辣眼睛
if symb=='SHSE.6000:请问这是什么语法。def定义函数后居然没有缩进
sysmbol是什么数据类型你都不知道，是个字典

jensonl

waitforlove 发表于 2018-3-2 16:10
真是辣眼睛
if symb=='SHSE.6000:请问这是什么语法。def定义函数后居然没有缩进
sysmbol是什么数据类型你 ...

copy的时候漏了。 修复了。  能关注问题重点吗。  数据类型当然是字典。 但我的问题不是这个

jensonl

waitforlove 发表于 2018-3-2 16:10
真是辣眼睛
if symb=='SHSE.6000:请问这是什么语法。def定义函数后居然没有缩进
sysmbol是什么数据类型你 ...

其中 symbol 里面我打包了很多个字符串列表。   

这个是我用pickle 打包的字符串列表，用来订阅N组 数据

waitforlove

没人一开始就是最简洁的，先用麻烦的方法写出来，再想怎么搞优化

jensonl

waitforlove 发表于 2018-3-2 18:05
没人一开始就是最简洁的，先用麻烦的方法写出来，再想怎么搞优化

程序已经正常运行了。 还请给些指导性的意见谢谢。

waitforlove

jensonl 发表于 2018-3-2 18:32
程序已经正常运行了。 还请给些指导性的意见谢谢。

你是要每秒返回一个数据吗

jensonl

waitforlove 发表于 2018-3-2 19:19
你是要每秒返回一个数据吗

不是每秒返回一个数据。 是这个subscribe() 会每秒传给我，每个字符串对应的数据组。
我要对数据进行分析处理。  是我问题不够明白吗

jensonl

求指导 没人能解答吗

看破天

很简单的，你在开头把"600001"这样要更改的数值赋值给一个变量，例如:先设置num=600001，nums=s+str(num)然后你的S600001=[]可以改为nums=[]，你的SHSE.600001可以改为SHSE.+str(num)以此类推。以后你只需要修改num的值就可以了

看破天

如果你想更省力，可以把num0=600000然后num1=num0+1=600001然后num2=600002以此类推。列表num0s=s+str(num0)以此类推

jensonl

已解决。