如何创建含try/catch的Flutter用户注册类？解决await报错问题

针对你遇到的两个问题，下面是重构后的完整类实现，同时解决await的异步函数要求和全局错误捕获问题：

核心实现代码 #

class GoogleEmailAuthService:
    def __init__(self, google_api_client):
        # 依赖注入Google API客户端，提升可测试性和扩展性
        self.google_client = google_api_client

    # 标记为async函数，才能使用await关键字
    async def register_via_google(self, email, extra_user_info):
        try:
            # 1. 异步验证Google邮箱合法性
            email_validity = await self.google_client.validate_email(email)
            if not email_validity:
                raise ValueError("该邮箱不属于Google账号")

            # 2. 异步创建用户数据记录
            user_record = await self._persist_user_data(email, extra_user_info)

            # 3. 异步发送注册确认邮件
            await self._dispatch_confirmation_email(user_record)

            return {"status": "success", "user_id": user_record.id}
        except Exception as err:
            # 捕获所有异常，统一处理错误逻辑
            # 可根据需求扩展：区分API错误、数据库错误等类型
            return {"status": "failed", "error_message": str(err)}

    # 私有异步辅助方法：持久化用户数据
    async def _persist_user_data(self, email, extra_info):
        # 替换为实际的异步数据库操作（如SQLAlchemy Async/AsyncPG）
        return type('User', (object,), {
            "id": 1001,
            "email": email,
            "full_name": extra_info.get("full_name")
        })()

    # 私有异步辅助方法：发送确认邮件
    async def _dispatch_confirmation_email(self, user):
        # 替换为实际的异步邮件服务调用（如aiohttp调用SendGrid API）
        print(f"已向 {user.email} 发送注册确认邮件")

关键问题解决说明 #

• await报错问题：所有包含await的方法（包括私有辅助方法）都必须标记为async，这是Python异步语法的硬性要求。
• 全局错误捕获：在核心的注册方法外层用try/catch包裹所有逻辑，既可以捕获异步操作抛出的异常，也能捕获同步逻辑（如参数校验）的错误，实现统一的错误处理。

调用示例 #

import asyncio

async def main():
    # 初始化Google API客户端（替换为实际的客户端实例）
    mock_google_client = type('GoogleClient', (object,), {
        "validate_email": lambda self, email: asyncio.sleep(0.1) or "@gmail.com" in email
    })()
    
    auth_service = GoogleEmailAuthService(mock_google_client)
    result = await auth_service.register_via_google("test@gmail.com", {"full_name": "John Doe"})
    print(result)

asyncio.run(main())

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