Я написал этот код python для получения событий socketio, но он не работает, хотя соединение успешно. Ниже приведен мой код. Подскажите, пожалуйста, что я делаю не так?
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
import socketio
import requests
socketEndpoint = 'wss://stream.abc.com'
sio = socketio.Client()
app = Flask(__name__)
db = SQLAlchemy()
app.config['SQLALCHEMY_DATABASE_URI']="db-url-here"
db.init_app(app)
sio.connect(socketEndpoint, transports = 'websocket')
sio.emit('join', { 'channelName': 'my-channel' })
print(sio)
import json
from sqlalchemy import text
@sio.on('new-trade')
def on_message(response):
print(response.data)
print("works")
if __name__ == '__main__':
app.run()