# Define una función para manejar los mensajes de Spark Driver def on_message(ws, message): print(f"Mensaje recibido: {message}")