Estoy creando una aplicación con los servicios de Google Cloud, la aplicación se implementa a través de Google App Engine.

Me gustaría mostrar información en tiempo real con Flask a través del método onSnapshot() de Firestore, así que traté de usar Flask_socketio para enviar la información al cliente, pero no funciona dentro de on_snapshot.

 from flask import Flask, render_template, request from google.cloud import firestore from flask_socketio import SocketIO, emit db = firestore.Client() app = Flask(__name__) socketio = SocketIO(app) @app.route("/", methods=["GET"]) def map(): live_ref = db.collection("events").document("live_events").get() return render_template("index.html", rec=live_ref.to_dict()["displayed_events"]) @socketio.on("test", namespace="/") def test(): def on_snapshot(doc_snapshot, changes, read_time): for doc in doc_snapshot: print(f"Received document snapshot: {doc.to_dict()}") with app.app_context(): emit("message", "test_message", namespace="/", broadcast=True) test_ref = db.collection("events").document("live_events") test_watch = test_ref.on_snapshot(on_snapshot) if __name__ == "__main__": socketio.run(app, debug=True)

índice.html

 $(document).ready(function() { var socket = io.connect('http://127.0.0.1:5000'); socket.on('connect', function() { socket.emit('test'); }); socket.on("message", function(msg) { $("#messages").append('<li>'+msg+'</li>'); }); }); </script> <ul id="messages"></ul>

Entonces, me preguntaba cómo podría resolverse el problema o qué otros métodos/servicios podrían usarse para poder recibir cambios de datos en tiempo real desde db firestore y mostrarlos en el lado del cliente. He visto que es posible usar on_snapshot directamente desde el cliente, pero me gustaría evitar usar firebase console.