Flask Socket IO 响应超时错误

Question

我试图在我的网页（实时）中始终从我的数据库中获得更新的表格。为此，我正在使用 Flask 和 SocketIO。但我收到以下错误：

at=error code=H12 desc="Request timeout" method=GET path="/socket.io/?EIO=3&transport=polling&t=NBIyASy&sid=bc2f86d8b04c4304aaf2a76211b3b6fa" host=pruebas-intranet.herokuapp.com request_id=2f725719-befa-4b1e-ba7b-5c025ad34a87 fwd="190.117.185.95" dyno=web.1 connect=1ms service=30001ms status=503 bytes=0 protocol=https

这里你可以看到我在flask中使用的代码：

from flask_socketio import SocketIO, emit, send

if(os.environ.get('DATABASE_URL') is None):
    raise Exception("Esta Faltando la variable: DATABASE_URI")

app = Flask(__name__)
app.secret_key = “…”

app.config['SQLALCHEMY_DATABASE_URI'] = os.environ.get('DATABASE_URL')

db = SQLAlchemy(app)

socketio = SocketIO(app)

from models import User

login_manager = LoginManager()
login_manager.login_view = 'login_post'
login_manager.init_app(app)
login_manager.login_message = u"Por favor ingrese sus credenciales."

@login_manager.user_loader
def load_user(user_id):
    return User.query.get(int(user_id))

@socketio.on('solicitudes_id')
async def broad_consolidado():
    consolidado_data = Consolidado.query.all()
    await socketio.emit('consolidado', consolidado_data, namespace='/consolidado')

@app.route('/consolidado')
@login_required
def show_consolidado():
    return render_template("consolidado.html")

if __name__ == "__main__":
    socketio.run(app, debug=True)

在我的 HTML 方面，我使用 JS 作为代码的一部分来显示表格：

            <div style="overflow: auto">
 

                <table id="dtHorizontalExample" class="table table-striped table-bordered table-sm" cellspacing="0" width="100%">
                    <thead>
                        <tr>
                            <th>solicitudes_id</th>
                            <th>id_user</th>
                            <th>tipouso</th>
                            <th>tipoauto</th>
                            <th>credito</th>
                            <th>entidadcrediticia</th>
                            <th>id_auto</th>
                            <th>fecha</th>
                            <th>canalinput</th>
                            <th>ciudadcompra</th>
                            <th>hora</th>
                            <th>nombre</th>
                            <th>appellidos</th>
                            <th>numdocumento</th>
                            <th>numtelefono</th>
                            <th>correo</th>
                            <th>tipolicencia</th>
                            <th>tiempolicencia</th>
                            <th>trabajoaplicativo</th>
                            <th>tipodocumento</th>
                        </tr>
                    </thead>

                    <tbody>

                        <script type="text/javascript">
                              var socket = io.connect('https://' + document.domain + ':' + location.port);
                              socket.on( 'consolidado', function( consolidado ) {
                                  for (var i = 0; i < consolidado.length; i++) {
                                        console.log( consolidado[i].solicitudes_id );
                                        $( 'tbody' ).append('<tr> <td>'+
                                            consolidado[i].solicitudes_id+ '</td> <td>'+
                                            consolidado[i].id_user+'</td> <td>' +
                                            consolidado[i].tipouso+ '</td> <td>'+
                                            consolidado[i].tipoauto+'</td> <td>'+
                                            consolidado[i].credito+ '</td> <td>'+
                                            consolidado[i].entidadcrediticia+'</td> <td>'+
                                            consolidado[i].id_auto+'</td> <td>'+
                                            consolidado[i].fecha+'</td> <td>'+
                                            consolidado[i].canalinput+'</td> <td>'+
                                            consolidado[i].ciudadcompra+'</td> <td>'+
                                            consolidado[i].hora+'</td> <td>'+
                                            consolidado[i].nombre+'</td> <td>'+
                                            consolidado[i].appellidos+'</td> <td>'+
                                            consolidado[i].numdocumento+'</td> <td>'+
                                            consolidado[i].numtelefono+'</td> <td>'+
                                            consolidado[i].correo+'</td> <td>'+
                                            consolidado[i].tipolicencia+'</td> <td>'+
                                            consolidado[i].tiempolicencia+'</td> <td>'+
                                            consolidado[i].trabajoaplicativo+'</td> <td>'+
                                            consolidado[i].tipodocumento+'</td> </tr>')
                                }
                              })
                        </script>

                    </tbody>
 
 
                </table>
            </div>

这是我的控制台错误：

谢谢，

乔纳森·普列托

Answer 1

我不确定这是否有助于回答您的问题，但您无法更改 Request.sid 值，它是由服务器选择的...

Answer 2

HTTP 503 错误表示请求解析存在错误。我不确定您是否正确设置了socketio，但请务必在需要时打开和关闭连接。

现在查看您的 sn-p，您调用 socketio.emit 函数并完成执行。问题是这个函数需要异步，所以你应该像这样使用async/await关键字

@socketio.on('solicitudes_id')
async def broad_consolidado():
    consolidado_data = Consolidado.query.all()
    await socketio.emit('consolidado', consolidado_data, namespace='/consolidado')

这样可以确保socketio.emit 在离开函数之前完成执行。