Python爬虫：利用aiowebsocket库抓取WebSocket数据

1、实时数据

aiowebsocket github：https://github.com/asyncins/aiowebsocket

2、安装：

pip install aiowebsocket

抓取莱特币官网实时数据 http://www.laiteb.com/

刷新页面观察请求 WebSocket 地址为：wss://api.bbxapp.vip/v1/ifcontract/realTime

1、数据交互模式为： 2、代码实例

# -*- coding: utf-8 -*-

import asyncio
from aiowebsocket.converses import AioWebSocket


async def startup(uri):
    async with AioWebSocket(uri) as aws:
        converse = aws.manipulator

        # 给服务端发送验证消息，观察网页接口数据动态获取
        message = '{"action":"subscribe","args":["QuoteBin5m:14"]}'
        await converse.send(message)

        while True:
            receive = await converse.receive()

            # 拿到的是byte类型数据，解码为字符串数据
            print(receive.decode())


if __name__ == '__main__':
    remote = 'wss://api.bbxapp.vip/v1/ifcontract/realTime'
    asyncio.get_event_loop().run_until_complete(startup(remote))

3、数据效果

参考: Python 如何爬取实时变化的 WebSocket 数据