Python虚拟环境中WebSocket回调函数不执行的深层原因与解决方案

class Command(BaseCommand):
    def handle(self, *args: Any, **options: Any):
        # ... API Keys and session generation ...

        print("Connecting to Breeze")
        breeze = BreezeConnect(api_key="")
        print("WebSocket connected successfully") # First print, possibly premature

        breeze.generate_session(api_secret="", session_token="")

        breeze.ws_connect()
        print("WebSocket connected successfully") # Second print, after actual connect

        def on_ticks(ticks):
            print("Ticks: {}".format(ticks))

        breeze.on_ticks = on_ticks

        breeze.subscribe_feeds(exchange_code="NFO", stock_code="ADAENT", product_type="options",
                        expiry_date="28-Dec-2023", strike_price="3000", right="Call",
                        get_exchange_quotes=True, get_market_depth=False)

        print("Subscribed to ADAENT options")

        breeze.ws_disconnect() # !!! Critical Issue !!!
        print("Disconnected from WebSocket")

import time
# ... (之前的代码保持不变，但要移除立即的 ws_disconnect()) ...

        print("Subscribed to ADAENT options")

        # 保持主线程活跃，等待接收数据
        # 方案A: 简单阻塞，等待用户输入退出
        input("Press Enter to exit the program and disconnect from WebSocket...")

        breeze.ws_disconnect()
        print("Disconnected from WebSocket")

import time
# ... (之前的代码保持不变，但要移除立即的 ws_disconnect()) ...

        print("Subscribed to ADAENT options")

        # 保持主线程活跃，等待接收数据
        # 方案B: 定时休眠，例如等待600秒（10分钟）
        print("Waiting for 600 seconds to receive ticks...")
        time.sleep(600) # 根据需要调整等待时间

        breeze.ws_disconnect()
        print("Disconnected from WebSocket")

import time
from typing import Any
from django.core.management.base import BaseCommand
from breezeconnect import BreezeConnect

class Command(BaseCommand):
    help = 'Connects to Breeze WebSocket and subscribes to market data.'

    def handle(self, *args: Any, **options: Any):
        api_key = "YOUR_API_KEY" # 替换为你的API Key
        api_secret = "YOUR_API_SECRET" # 替换为你的API Secret
        session_token = "YOUR_SESSION_TOKEN" # 替换为你的Session Token

        print("Initializing BreezeConnect...")
        breeze = BreezeConnect(api_key=api_key)

        print("Generating session...")
        breeze.generate_session(api_secret=api_secret, session_token=session_token)

        print("Connecting to WebSocket...")
        breeze.ws_connect()
        print("WebSocket connected successfully.")

        def on_ticks(ticks):
            """
            WebSocket回调函数，用于处理接收到的行情数据。
            """
            print(f"Received Ticks: {ticks}")

        # 注册回调函数
        breeze.on_ticks = on_ticks

        # 订阅行情数据
        # 请根据实际需求修改订阅参数
        breeze.subscribe_feeds(
            exchange_code="NFO", 
            stock_code="ADAENT", 
            product_type="options",
            expiry_date="28-Dec-2023", 
            strike_price="3000", 
            right="Call",
            get_exchange_quotes=True, 
            get_market_depth=False
        )

        print("Subscribed to ADAENT options. Waiting for ticks...")

        try:
            # 保持主线程活跃，持续接收数据
            # 这里使用input()作为示例，实际应用中可能需要更复杂的事件循环或信号处理
            input("Press Enter to stop subscription and disconnect from WebSocket...")
        except KeyboardInterrupt:
            print("\nProgram interrupted by user.")
        finally:
            # 在程序退出前断开WebSocket连接
            if breeze:
                breeze.ws_disconnect()
                print("Disconnected from WebSocket.")
            print("Program terminated.")