实现服务器间非阻塞通信：Python Flask与Laravel的异步交互策略

# app.py
from flask import Flask, jsonify
import asyncio
import aiohttp

app = Flask(__name__)

# 假设Laravel服务器的地址
LARAVEL_API_URL = "http://localhost:8000/api/latest_data"

@app.route('/process_data_async')
async def process_data_async():
    """
    一个异步Flask视图函数，向Laravel服务器请求数据。
    """
    try:
        async with aiohttp.ClientSession() as session:
            async with session.get(LARAVEL_API_URL) as response:
                response.raise_for_status() # 检查HTTP响应状态
                laravel_data = await response.json()

        # 在这里可以对从Laravel获取的数据进行机器学习处理
        processed_result = {"status": "success", "data_from_laravel": laravel_data, "ml_output": "some_ml_result"}
        return jsonify(processed_result)
    except aiohttp.ClientError as e:
        return jsonify({"status": "error", "message": f"Failed to fetch data from Laravel: {e}"}), 500
    except Exception as e:
        return jsonify({"status": "error", "message": f"An unexpected error occurred: {e}"}), 500

if __name__ == '__main__':
    # 为了运行异步Flask应用，需要使用ASGI服务器，如Uvicorn
    # 例如：uvicorn app:app --host 0.0.0.0 --port 5000
    # 或者在开发环境中，可以直接运行Flask自带的开发服务器，但其异步能力有限
    # app.run(debug=True)
    print("To run this Flask application with async support, use Uvicorn:")
    print("uvicorn app:app --host 0.0.0.0 --port 5000")

# main.py (Starlette示例)
from starlette.applications import Starlette
from starlette.responses import JSONResponse
from starlette.routing import Route
import aiohttp

LARAVEL_API_URL = "http://localhost:8000/api/latest_data"

async def homepage(request):
    try:
        async with aiohttp.ClientSession() as session:
            async with session.get(LARAVEL_API_URL) as response:
                response.raise_for_status()
                laravel_data = await response.json()

        processed_result = {"status": "success", "data_from_laravel": laravel_data, "ml_output": "another_ml_result"}
        return JSONResponse(processed_result)
    except aiohttp.ClientError as e:
        return JSONResponse({"status": "error", "message": f"Failed to fetch data from Laravel: {e}"}, status_code=500)
    except Exception as e:
        return JSONResponse({"status": "error", "message": f"An unexpected error occurred: {e}"}, status_code=500)

routes = [
    Route("/process_data_starlette", endpoint=homepage),
]

app = Starlette(routes=routes)

# 运行此应用需要Uvicorn: uvicorn main:app --host 0.0.0.0 --port 8000

import asyncio
import aiohttp

async def fetch_data_from_laravel(url: str):
    """
    使用aiohttp异步请求Laravel服务器数据。
    """
    async with aiohttp.ClientSession() as session:
        try:
            async with session.get(url) as response:
                response.raise_for_status() # 如果状态码不是2xx，会抛出异常
                data = await response.json()
                return data
        except aiohttp.ClientError as e:
            print(f"Error fetching data: {e}")
            return None

async def main():
    laravel_data = await fetch_data_from_laravel("http://localhost:8000/api/latest_data")
    if laravel_data:
        print("Received data from Laravel:", laravel_data)
    else:
        print("Failed to retrieve data.")

if __name__ == '__main__':
    # 运行异步函数
    asyncio.run(main())