Slack Bolt模态框超时未关闭求助（AWS Lambda+Okta场景）

核心思路 #

Slack强制要求表单提交请求必须在3秒内返回ack()响应，后续的Okta认证、主逻辑调用等耗时操作必须完全异步执行，绝对不能阻塞ack的返回。如果之前把认证逻辑移到ack后仍失败，大概率是当前Lambda函数因为后续同步代码执行过长，导致API Gateway无法及时把ack响应返回给Slack。

具体实现方案 #

1. 确保ack()是第一执行操作 #

不管任何前置逻辑，先调用ack()确认收到请求，这一步必须放在最开头，不能有任何阻塞：

from slack_bolt import App

app = App(token="SLACK_BOT_TOKEN")

@app.view("your_modal_id")
def handle_modal_submission(ack, body, logger):
    # 第一步：立即返回ack，无任何额外逻辑
    ack()
    
    # 后续耗时逻辑全部丢到异步流程
    trigger_async_processing(body)

2. 将耗时逻辑完全异步化 #

必须把Okta认证、主逻辑Lambda调用从当前同步Lambda中剥离，用以下两种方式实现异步：

方式一：用SQS队列触发后续处理

• 当前Lambda只做ack+发送表单数据到SQS，然后立即结束
• 另一个Lambda监听SQS队列，收到消息后执行认证和主逻辑

当前Lambda代码：

import boto3
import json
from slack_bolt import App

app = App(token="SLACK_BOT_TOKEN")
sqs = boto3.client('sqs', region_name='your-region')
QUEUE_URL = "your-sqs-queue-url"

@app.view("your_modal_id")
def handle_modal_submission(ack, body, logger):
    ack()
    
    # 序列化表单数据发送到SQS
    try:
        modal_values = body["view"]["state"]["values"]
        sqs.send_message(
            QueueUrl=QUEUE_URL,
            MessageBody=json.dumps(modal_values)
        )
        logger.info("Modal data queued for processing")
    except Exception as e:
        logger.error(f"Failed to send to SQS: {str(e)}")

def lambda_handler(event, context):
    return app.process_event(event)

处理SQS消息的Lambda代码：

import boto3
import json
import okta_client

lambda_client = boto3.client('lambda', region_name='your-region')
okta_api = okta_client.Client(okta_domain="your-okta-domain", api_token="your-okta-token")

def process_sqs_event(event, context):
    for record in event['Records']:
        modal_data = json.loads(record['body'])
        
        # 执行Okta认证
        try:
            user_auth = okta_api.authenticate_user(...)
            if not user_auth.get("status") == "SUCCESS":
                # 记录认证失败日志，可额外通知管理员
                continue
        except Exception as e:
            logger.error(f"Okta auth failed: {str(e)}")
            continue
        
        # 异步调用主逻辑Lambda
        lambda_client.invoke(
            FunctionName="your-main-logic-lambda",
            InvocationType="Event",
            Payload=json.dumps(modal_data)
        )

方式二：直接异步调用处理Lambda

如果不想用SQS，可直接在ack后触发另一个Lambda异步执行，确保当前函数立即结束：

import boto3
import json
from slack_bolt import App

app = App(token="SLACK_BOT_TOKEN")
lambda_client = boto3.client('lambda', region_name='your-region')

@app.view("your_modal_id")
def handle_modal_submission(ack, body, logger):
    ack()
    
    try:
        modal_values = body["view"]["state"]["values"]
        # 关键参数：InvocationType="Event" 表示异步调用
        lambda_client.invoke(
            FunctionName="your-processing-lambda",
            InvocationType="Event",
            Payload=json.dumps(modal_values)
        )
        logger.info("Processing triggered asynchronously")
    except Exception as e:
        logger.error(f"Failed to trigger processing: {str(e)}")

def lambda_handler(event, context):
    return app.process_event(event)

3. 排查之前方案失效的可能原因 #

• API Gateway超时过短：虽然Slack要求3秒，但如果API Gateway设置的超时小于当前Lambda执行时间（即使ack先执行，后续同步代码仍会占用时间），会导致API Gateway返回504，Slack收不到ack。此时必须让当前Lambda在ack后立即结束，无任何阻塞。
• ack后仍有同步阻塞代码：比如你之前把Okta认证移到ack后，但还是同步调用，这会占用Lambda执行时间，导致整个函数超时。必须把这些操作完全异步化。

额外注意事项 #

• 异步任务的失败（认证失败、主逻辑报错）要单独记录日志，必要时通知管理员，因为Slack已经收到ack，用户看不到后续错误。
• 传递数据时用json.dumps/json.loads序列化，避免解析错误，不要用str()或eval()。

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