如何让Python AWS Lambda handler执行长时异步调用并立即返回请求ID

你当前的写法是不可行的，直接调用异步函数不加await也不做其他处理时，并不会执行函数内部的逻辑，只会生成一个未执行的协程对象，该对象被垃圾回收时还会抛出RuntimeWarning: coroutine 'xxx' was never awaited的警告。

针对你需要的「触发即忽略、不需要等待异步函数返回结果」的需求，可按场景选择对应实现方案： #

场景1：框架支持异步handler #

如果你的业务框架允许将handler定义为异步函数（比如FastAPI路由、支持异步处理的Serverless框架等），可以直接用asyncio.create_task()将协程提交给当前运行的事件循环调度，不需要等待执行完成即可返回：

import asyncio
import random

async def someAsyncFunction():
    # 你的异步业务逻辑
    await asyncio.sleep(3)
    print("异步任务执行完成")

# 异步handler
async def my_handler(event, context):
    # 提交异步任务到事件循环，无需await
    task = asyncio.create_task(someAsyncFunction())
    # 可选：添加异常处理回调，避免任务异常无感知
    def catch_exception(task):
        try:
            task.result()
        except Exception as e:
            print(f"异步任务执行出错：{str(e)}")
    task.add_done_callback(catch_exception)
    return random.randint(10000, 99999)

场景2：handler只能为同步函数 #

如果你的业务框架不支持异步handler，必须使用同步定义，可以通过后台线程单独运行事件循环来执行异步逻辑，不阻塞当前handler返回：

import asyncio
import random
import threading

async def someAsyncFunction():
    # 你的异步业务逻辑
    await asyncio.sleep(3)
    print("异步任务执行完成")

def run_async_task():
    loop = asyncio.new_event_loop()
    asyncio.set_event_loop(loop)
    try:
        loop.run_until_complete(someAsyncFunction())
    except Exception as e:
        print(f"异步任务执行出错：{str(e)}")
    finally:
        loop.close()

# 同步handler
def my_handler(event, context):
    # 启动守护线程执行异步任务
    threading.Thread(target=run_async_task, daemon=True).start()
    return random.randint(10000, 99999)

注意事项 #

• 上述两种方案都存在进程提前退出导致异步任务未执行完成的风险，如果你的服务是短生命周期实例（比如Serverless函数、单次运行的脚本），建议将异步逻辑转为消息队列投递到独立的消费服务处理，避免任务丢失。
• 异步任务抛出的异常如果没有额外捕获处理，不会影响主handler的正常返回，但也不会主动上报，建议统一添加异常捕获逻辑避免问题无感知。

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