为什么我不能在函数中使用 websocket

Question

当我尝试像这样使用 websocket 时

ws = websocket.WebSocketApp(f"wss://fstream.binance.com/ws/{symbol}@aggTrade",on_message=on_message,on_close=on_close)
ws.run_forever()

它工作正常，但出于某种原因我想像这样使用它

def func(symbol):
    ws = websocket.WebSocketApp(f"wss://fstream.binance.com/ws/{symbol}@aggTrade",on_message=on_message,on_close=on_close)
    ws.run_forever()
func("btcusdt")

但它不起作用为什么我不能在 func 中使用 websocket 我该怎么做

Answer 1

这（由于 SSL 问题对 OP 的代码进行了微小的更改）在 Python 3.9.9 上完美运行

import websocket
import ssl


def on_msg(_, msg):
    print(msg)


def on_err(_, err):
    print(err)


def func(symbol):
    ws = websocket.WebSocketApp(
        f"wss://fstream.binance.com/ws/{symbol}@aggTrade", on_message=on_msg, on_error=on_err)
    ws.run_forever(sslopt={"cert_reqs": ssl.CERT_NONE})


if __name__ == '__main__':
    func('btcusdt')