Other Subscription Events

import time

from tigeropen.push.push_client import PushClient
from tigeropen.tiger_open_config import get_client_config
client_config = get_client_config(private_key_path='private key path', tiger_id='your tiger id', account='your account')

# Initialize PushClient
protocol, host, port = client_config.socket_host_port
push_client = PushClient(host, port, use_ssl=(protocol == 'ssl'))


def connect_callback(frame):
    """Handle a successful connection."""
    print('connected')
    
push_client.connect_callback = connect_callback

def disconnect_callback():
    """Reconnect after disconnection"""
    for t in range(1, 200):
        try:
            print('disconnected, reconnecting...')
            push_client.connect(client_config.tiger_id, client_config.private_key)
        except Exception:
            print('connect failed, retry')
            time.sleep(t)
        else:
            print('reconnect success')
            break
            
# Initialize push_client as shown above
push_client.disconnect_callback = disconnect_callback   
   

def error_callback(frame):
    """Handle a connection error.

    :param frame: Error information.
    """
    print(frame)

# Initialize push_client as shown above
push_client.error_callback = error_callback

import logging

logger = logging.getLogger(__name__)

def kickout_callback(frame):
    logger.error(f'kickout callback: {frame}')
    
push_client.kickout_callback = kickout_callback