事件驱动（subscribe）示例，如何将回调函数callback_func不写在init里

本帖最后由 ***4137 于 2023-12-30 22:19 编辑

#coding:gbk

class a():pass
A = a()
A.bought_list = []

account = 'testaccount'
def init(C):
    #下单函数的参数需要 ContextInfo对象 在init中定义行情回调函数 可以用到init函数的入参 不用手动传入 
    def callback_func(data):
        #print(data)
        for stock in data:
            current_price = data[stock]['close']
            pre_price = data[stock]['preClose']
            ratio = current_price / pre_price - 1
            print(stock, C.get_stock_name(stock), '当前涨幅', ratio)
            if ratio > 0 and stock not in A.bought_list:
                msg = f"当前涨幅 {ratio} 大于0 买入100股"
                print(msg)
                #下单函数passorder 安全起见处于注释状态 需要实际测试下单交易时再放开
                #passorder(23, 1101, account, stock, 5, -1, 100, '订阅下单示例', 2, msg, C)
                A.bought_list.append(stock)
    stock_list = ['600000.SH', '000001.SZ']
    for stock in stock_list:
        C.subscribe_quote(stock, period = '1d', callback = callback_func)

事件驱动（subscribe）示例，如何将回调函数callback_func不写在init里，写在外面跟init同级，写在外面的callback_func也需要用到ContextInfo，刚学习求帮助

1. #encoding:gbk
   
2. import time
   
3. from functools import partial
   
4. 
   
5. 
   
6. def init(ContextInfo):
   
7.         s = '000001.SZ'
   
8.         ContextInfo.subscribe_quote(s,
   
9.                                                 period='tick',
   
10.                                                 dividend_type='follow',
    
11.                                                 result_type='dict',
    
12.                                                 callback=partial(on_subscribe, ContextInfo,'tick')) # 用 partial扩展回调参数
    
13.         ContextInfo.subscribe_quote(s,
    
14.                                                 period='1m',
    
15.                                                 dividend_type='follow',
    
16.                                                 result_type='dict',
    
17.                                                 callback=partial(on_subscribe, ContextInfo,'1m'))  # 用 partial扩展回调参数
    
18.        
    
19.        
    
20. def on_subscribe(ContextInfo, period, data):
    
21.         # ContextInfo、period 用partial 扩展的参数
    
22.         print(ContextInfo,period, data)
    

复制代码