Connection to websocket via socketio package

README.md

Before run:

pip install requests python-socketio

Run:

python main.py

main.py

import socketio

sio = socketio.Client(logger=True)


@sio.event
def connect():
    print("Connected")


@sio.event
def disconnect():
    print("Disconnected")


@sio.event
def connect_error(error):
    print(error)


@sio.event
def message(data):
    print(data)


@sio.on("new-block", namespace="/stream")
def new_block_event(data):
    print(data)


@sio.on("new-txs", namespace="/stream")
def new_txs_event(data):
    print(data)


def main(client):
    client.connect(
        "https://redacted.com/stream/",
        socketio_path="/api/1.0/stream",
        transports=("websocket"),
        namespaces=["/stream"]
    )
    client.wait()


if __name__ == "__main__":
    main(sio)