如何使用python连接到lightstreamer



我想用python 连接到lightstramer

lightstreamer示例

我试试

import asyncio
import websockets as websockets
header = {
'Accept-Encoding': 'gzip, deflate, br',
'Accept-Language': 'en-US,en;q=0.9,fa;q=0.8',
'Cache-Control': 'no-cache',
'Connection': 'Upgrade',
'Host': 'push.lightstreamer.com',
'Origin': 'https://demos.lightstreamer.com',
'Pragma': 'no-cache',
'Sec-WebSocket-Extensions': 'permessage-deflate; client_max_window_bits',
'Sec-WebSocket-Key': '0JsNTUnSx4IOsbmuLusyaw==',
'Sec-WebSocket-Protocol': 'TLCP-2.1.0.lightstreamer.com',
'Sec-WebSocket-Version': '13',
'Upgrade': 'websocket',
'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/80.0.3987.163 '
'Safari/537.36',
}
async def hello():
async with websockets.connect('wss://push.lightstreamer.com/lightstreamer', extra_headers=header) as websocket:
greeting = await websocket.recv()
print(greeting)
asyncio.get_event_loop().run_until_complete(hello())

但总是得到错误

websockets.exceptions.InvalidStatusCode: server rejected WebSocket connection: HTTP 400

我如何连接到这个并获取数据??我需要什么图书馆?

目前,Lightstreamer不提供官方的python客户端库,但您可以利用这个简单的示例,该示例使用HTTP Streaming与Lightstreamer服务器实例进行通信。

此外,有关如何实现通信协议的更多详细信息,请参阅TLCP规范。

最新更新