以毫秒（Binance Websocket）获取现场价格

Question

如何更改代码，以便每100毫秒获得信息？

import asyncio
from binance import AsyncClient, BinanceSocketManager


async def main():
    client = await AsyncClient.create()
    bm = BinanceSocketManager(client)
    # start any sockets here, i.e a trade socket
    ts = bm.trade_socket('BTCBUSD')
    # then start receiving messages
    async with ts as tscm:
        while True:
            res = await tscm.recv()
            print(res)

    await client.close_connection()

if __name__ == "__main__":

    loop = asyncio.get_event_loop()
    loop.run_until_complete(main())

我会得到我能得到的每个答案，非常感谢！

Answer 1

尝试一下：

import asyncio
import websockets
import json

async def hello():
    async with websockets.connect("wss://stream.binance.com:9443/ws/btcusdt@bookTicker") as ws:
        while True:
            response = await asyncio.wait_for(ws.recv(), timeout=2)
            response=json.loads(response)
            print(response)
            await asyncio.sleep(0.5)

asyncio.get_event_loop().run_until_complete(hello())

Answer 2

您询问了“如何以毫秒（Binance websocket）获得实时价格”，

这是一个可用的binance流的列表，其中包含“ update speed”的可用选项： https://github.com/binance/binance/binance-binance-spot-apot-api-docs一下/blob/master/web-socket-streams.md#detailed-stream-information

因为我理解大多数流类型都在更新一次（更新速度：1000ms）。

只有深度流可以更新10次每秒10次（1000ms和100ms间隔）

贸易流（AGG和正常），并且BookTicker（个人和所有）是实时的。这意味着，只要有此信息，您就会收到...

如果没有交易，您将不会收到任何东西，因为价格没有变化...但是，一旦交易发生，它就会报告了给你。

如果您想知道，当前的买卖价格可用于资产，您可以使用Bookticker，而Bookticker与深度和差异相比要少得多。深度流...如果您需要的是当前订单的最初位置，我建议使用本地深度缓存： https://www.lucit.tech/unicorn-binance-local-local-depth-cache.html

要获得稳定的Websocket连接，我建议使用 Unicorn Binance binance binance websocket api ，它会捕获大多数例外，并在脱节后自动重新连接（它使用asyncio insions（它）回调函数在事件循环中），使用它的语法很容易：

from unicorn_binance_websocket_api.manager import BinanceWebSocketApiManager


def process_new_receives(stream_data, stream_buffer_name=False):
    print(str(stream_data))


ubwa = BinanceWebSocketApiManager(exchange="binance.com")
ubwa.create_stream('trade',
                   ['ethbtc', 'btcusdt', 'bnbbtc', 'ethbtc'],
                   process_stream_data=process_new_receives)

Answer 3

由于您似乎很着急，所以下面是我使用的，尽管我正在使用WebSockets库来拨打电话。当我有更多时间看看是否可以接到更快的电话时，我会看一下Binance API，但这应该可以实现您想要的。

您可以通过更改的睡眠时间来更改请求之间的延迟。 （违反政策）要求太多；然后发送1008（违反政策）请求太多

import asyncio
import websockets
import json

msg = {"method": "SUBSCRIBE", "params":
        [
        "btcusdt@depth"
        ],
        "id": 1
        }

async def call_api():
    async with websockets.connect('wss://stream.binance.com:9443/ws/btcusdt@depth') as ws:
        while True:
            await ws.send(json.dumps(msg))
            response = await asyncio.wait_for(ws.recv(), timeout=2)
            response = json.loads(response)
            print(response)
            await asyncio.sleep(0.5)

asyncio.get_event_loop().run_until_complete(call_api())