enum param optimization

Author: tigersk

requirements.txt

@@ -1,6 +1,6 @@
 simplejson==3.17.3
 delorean==1.0.0
-pandas==1.1.5
+pandas
 python-dateutil==2.8.2
 pytz==2021.1
 pyasn1==0.4.8

tigeropen/examples/push_client_demo.py

@@ -120,25 +120,30 @@ def unsubscribe_callback(destination, content):
     print('subscribe:{}, callback content:{}'.format(destination, content))
 
 
-# def connect_callback():
-#     """连接建立回调"""
-#     print('connected')
-#
-#
-# def disconnect_callback():
-#     """连接断开回调. 此处利用回调进行重连"""
-#     for t in range(1, 200):
-#         try:
-#             print('disconnected, reconnecting')
-#             push_client.connect(client_config.tiger_id, client_config.private_key)
-#         except:
-#             print('connect failed, retry')
-#             time.sleep(t)
-#         else:
-#             print('reconnect success')
-#             return
-#     print('reconnect failed, please check your network')
-#
+def error_callback(content):
+    """错误回调"""
+    print(content)
+
+
+def connect_callback():
+    """连接建立回调"""
+    print('connected')
+
+
+def disconnect_callback():
+    """连接断开回调. 此处利用回调进行重连"""
+    for t in range(1, 200):
+        try:
+            print('disconnected, reconnecting')
+            push_client.connect(client_config.tiger_id, client_config.private_key)
+        except:
+            print('connect failed, retry')
+            time.sleep(t)
+        else:
+            print('reconnect success')
+            return
+    print('reconnect failed, please check your network')
+
 
 if __name__ == '__main__':
     client_config = get_client_config()
@@ -150,21 +155,24 @@ def unsubscribe_callback(destination, content):
     # 已订阅 symbol 查询回调
     push_client.subscribed_symbols = on_query_subscribed_quote
     # 订单变动回调
-    # push_client.order_changed = on_order_changed
+    push_client.order_changed = on_order_changed
     # 资产变动回调
-    # push_client.asset_changed = on_asset_changed
+    push_client.asset_changed = on_asset_changed
     # 持仓变动回调
-    # push_client.position_changed = on_position_changed
+    push_client.position_changed = on_position_changed
 
     # 订阅成功与否的回调
     push_client.subscribe_callback = subscribe_callback
     # 退订成功与否的回调
     push_client.unsubscribe_callback = unsubscribe_callback
 
+    # 错误信息回调
+    push_client.error_callback = error_callback
+
     # 建立推送连接
     push_client.connect(client_config.tiger_id, client_config.private_key)
     # 断线重连回调
-    # push_client.disconnect_callback = disconnect_callback
+    push_client.disconnect_callback = disconnect_callback
 
     # 订阅行情
     push_client.subscribe_quote(['AAPL', 'GOOG'])

tigeropen/quote/quote_client.py

@@ -4,7 +4,6 @@
 
 @author: gaoan
 """
-import enum
 import logging
 import re
 

tigeropen/tiger_open_client.py

@@ -99,7 +99,7 @@ def __prepare_request(self, request):
 
         log_url = self.__config.server_url + '?' + sign_content + "&sign=" + sign
         if THREAD_LOCAL.logger:
-            THREAD_LOCAL.logger.info('[' + THREAD_LOCAL.uuid + ']request:' + log_url)
+            THREAD_LOCAL.logger.debug('[' + THREAD_LOCAL.uuid + ']request:' + log_url)
 
         return all_params
 
@@ -110,7 +110,7 @@ def __prepare_request(self, request):
     def __parse_response(self, response_str, timestamp=None):
         response_str = response_str.decode(self.__config.charset)
         if THREAD_LOCAL.logger:
-            THREAD_LOCAL.logger.info('[' + THREAD_LOCAL.uuid + ']response:' + response_str)
+            THREAD_LOCAL.logger.debug('[' + THREAD_LOCAL.uuid + ']response:' + response_str)
 
         response_content = json.loads(response_str)