如何在FastAPI应用中配置ib_insync并解决事件循环冲突？

问题原因 #

你遇到的RuntimeError: This event loop is already running错误，是因为ib.connect()是同步方法，它会尝试启动自己的事件循环，但FastAPI（通过Uvicorn等ASGI服务器）已经在运行一个事件循环，两者冲突导致报错。

可行方案及实现步骤 #

完全可以在FastAPI中集成ib_insync，需要通过异步连接方式适配FastAPI的事件循环，并将IB实例全局共享。

1. 创建全局共享的IB实例

新建一个单独的模块（比如core/ib_client.py）来存放IB实例，确保应用内所有文件都能导入使用：

# core/ib_client.py
from ib_insync import IB

# 创建单例IB实例
ib = IB()

2. 修改FastAPI主文件，使用异步连接和生命周期管理

在main.py中，通过FastAPI的lifespan上下文管理IB连接的启动和关闭，使用异步版本的connectAsync()替代同步的connect()：

from fastapi import FastAPI, Lifespan
from fastapi.middleware.cors import CORSMiddleware
from .routers import auth, profile
from decouple import config
from .utils.constants import app_name
from .core.ib_client import ib

FRONTEND_DOMAIN = config("FRONTEND_DOMAIN")

# 定义应用生命周期，管理IB连接
async def lifespan(app: FastAPI):
    # 启动时异步连接IB Gateway
    await ib.connectAsync(
        host="127.0.0.1",
        port=7497,
        clientId=1,
        timeout=30  # 可根据需要调整超时时间
    )
    yield  # 应用运行期间保持连接
    # 关闭时断开IB连接
    ib.disconnect()

app = FastAPI(lifespan=lifespan)

app.add_middleware(
    CORSMiddleware,
    allow_origins=[FRONTEND_DOMAIN],
    allow_credentials=True,
    allow_methods=["*"],
    allow_headers=["*"],
)

app.include_router(auth.router)
app.include_router(profile.router)

@app.get("/")
async def home():
    return {"Welcome to the": f"{app_name} API"}

3. 在路由或其他模块中使用IB实例

在任意需要的模块（比如路由文件）中，直接导入全局IB实例即可使用，优先调用异步方法（以Async结尾）适配FastAPI的异步环境：

# routers/auth.py
from fastapi import APIRouter
from ..core.ib_client import ib

router = APIRouter()

@router.get("/account-summary")
async def get_account_summary():
    # 使用异步方法获取账户摘要
    account_summary = await ib.reqAccountSummaryAsync()
    return {"account_summary": [str(item) for item in account_summary]}

注意事项 #

• 优先使用ib_insync提供的异步方法（如reqContractDetailsAsync()、reqAccountSummaryAsync()），避免在异步路由中调用同步方法导致阻塞。
• 如果必须调用同步方法，可通过asyncio.to_thread()将其包装在线程池中运行：

  import asyncio
  
  @router.get("/some-sync-operation")
  async def sync_operation():
      result = await asyncio.to_thread(ib.some_sync_method)
      return {"result": result}
  

• 确保IB Gateway已正确启动，且端口、clientId与代码配置一致（7497为paper交易默认端口，7496为live交易端口）。

内容的提问来源于stack exchange，提问作者Cole