可以让Binance threadwebsocketmanager显示价格流

发布于 2025-02-06 22:26:21 字数 783 浏览 3 评论 0原文

我目前正在尝试从binance流式传输实时价格,但是在运行代码后,即使程序正在运行,我也会看到一个空白屏幕。

以下是代码:

import os
from binance.client import Client
import time
from binance import ThreadedWebsocketManager
from binance import ThreadedDepthCacheManager

api_key = os.environ.get('api_key')
api_secret = os.environ.get('api_secret')
client = Client(api_key, api_secret)

def main():

    symbol = 'BTCUSDT'
    twm = ThreadedWebsocketManager(api_key=api_key, api_secret=api_secret)
    
    #Start is required to initialise its internal loop
    twm.start()

    def handle_socket_message(msg):
        print(f"message type: {msg['e']}")
        print(msg)

    twm.start_kline_socket(callback=handle_socket_message, symbol=symbol)
    
    twm.join()

if __name__ == "__main__":
   main()

I am currently trying to stream live prices from, Binance but after running the code I see a blank screen even though the program is running.

Below is the code:

import os
from binance.client import Client
import time
from binance import ThreadedWebsocketManager
from binance import ThreadedDepthCacheManager

api_key = os.environ.get('api_key')
api_secret = os.environ.get('api_secret')
client = Client(api_key, api_secret)

def main():

    symbol = 'BTCUSDT'
    twm = ThreadedWebsocketManager(api_key=api_key, api_secret=api_secret)
    
    #Start is required to initialise its internal loop
    twm.start()

    def handle_socket_message(msg):
        print(f"message type: {msg['e']}")
        print(msg)

    twm.start_kline_socket(callback=handle_socket_message, symbol=symbol)
    
    twm.join()

if __name__ == "__main__":
   main()

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(1

追星践月 2025-02-13 22:26:21
from binance.streams import ThreadedWebsocketManager
from binance.streams import ThreadedDepthCacheManager

api_key = os.environ.get('api_key')
api_secret = os.environ.get('api_secret')

def main():
    symbol = 'BTCUSDT'        
    
    def handle_socket_message(msg):
        print(f"message type: {msg['e']}")
        print(msg)
    twm = ThreadedWebsocketManager(api_key=api_key, api_secret=api_secret)
    twm.start()

    twm.start_kline_socket(callback=handle_socket_message, symbol=symbol)
    twm.join()

if __name__ == "__main__":
    main()
    while True:
        pass
from binance.streams import ThreadedWebsocketManager
from binance.streams import ThreadedDepthCacheManager

api_key = os.environ.get('api_key')
api_secret = os.environ.get('api_secret')

def main():
    symbol = 'BTCUSDT'        
    
    def handle_socket_message(msg):
        print(f"message type: {msg['e']}")
        print(msg)
    twm = ThreadedWebsocketManager(api_key=api_key, api_secret=api_secret)
    twm.start()

    twm.start_kline_socket(callback=handle_socket_message, symbol=symbol)
    twm.join()

if __name__ == "__main__":
    main()
    while True:
        pass
~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文