智能体回调

功能概述

当智能体在运行过程中触发某些事件时，阿里云将主动向您的服务器发送请求。在接收到回调请求后，您可以添加相应的业务逻辑处理。

配置智能体回调

回调消息体字段说明

消息体示例：

{
    "aiAgentId":"0d31c************b3c787",
    "instanceId":"39f8e0bc005e4f309379*********",
    "event":"agent_start",
    "code":1001,
    "message":"User has been kicked from the room",
    "timestamp":"2023-10-01T12:00:00Z"
}

Server 示例

Python

from aiohttp import web
import json
from loguru import logger

async def handle_post(request):
    """
    处理POST请求并记录接收到的数据。
    """
    # 获取请求头中的Authorization
    authorization_header = request.headers.get('Authorization')
    if authorization_header is None or not authorization_header.startswith('Bearer fixed-token'):
        logger.error("Unauthorized request")
        return web.Response(status=401, text='Unauthorized')

    try:
        # 从请求体中获取数据
        callback_data = await request.json()

        logger.info("Parsed JSON data:")
        logger.info(json.dumps(callback_data, indent=4))

        return web.Response(text='Callback received successfully', status=200)
    except json.JSONDecodeError:
        # 如果JSON解析失败，则返回错误响应
        return web.Response(text='Invalid JSON', status=400)

app = web.Application()
app.add_routes([web.post('/', handle_post)])

if __name__ == '__main__':
    web.run_app(app, host='localhost', port=8081) 

回调事件状态码