WatsonX Assistant V2：理解动作触发机制与最佳实践

import json
from ibm_watson import AssistantV2
from ibm_cloud_sdk_core.authenticators import IAMAuthenticator

# --- 配置信息 ---
# 替换为您的WatsonX Assistant API Key
api_key = "YOUR_WATSONX_ASSISTANT_API_KEY"
# 替换为您的WatsonX Assistant 服务URL (例如: "https://api.us-south.assistant.watson.cloud.ibm.com")
service_url = "YOUR_WATSONX_ASSISTANT_SERVICE_URL"
# 替换为您的Assistant ID
assistant_id = "YOUR_ASSISTANT_ID"
# --- 配置信息结束 ---

# 初始化认证器
authenticator = IAMAuthenticator(api_key)
assistant = AssistantV2(
    version='2021-11-27', # 建议使用最新的API版本
    authenticator=authenticator
)
assistant.set_service_url(service_url)

session_id = None
try:
    # 1. 创建新会话
    response = assistant.create_session(assistant_id=assistant_id).get_result()
    session_id = response['session_id']
    print(f"会话已创建: {session_id}")

    # 2. 用户消息，不包含任何显式的动作ID
    user_input = "我想预订一个从北京到上海的航班"

    # 3. 发送消息到Assistant
    message_response = assistant.message(
        assistant_id=assistant_id,
        session_id=session_id,
        input={
            'message_type': 'text',
            'text': user_input,
            # 'options': { 'return_context': True } # 如果需要返回上下文，可以添加此项
        }
    ).get_result()

    print("\nWatsonX Assistant 响应:")
    print(json.dumps(message_response, indent=2, ensure_ascii=False))

except Exception as e:
    print(f"发生错误: {e}")
finally:
    # 4. 删除会话 (重要：生产环境中应在会话结束时删除)
    if session_id:
        try:
            assistant.delete_session(assistant_id=assistant_id, session_id=session_id)
            print(f"\n会话 {session_id} 已删除.")
        except Exception as e:
            print(f"删除会话时发生错误: {e}")

# --- 配置信息 ---
# 替换为您的WatsonX Assistant API Key
API_KEY="YOUR_WATSONX_ASSISTANT_API_KEY"
# 替换为您的WatsonX Assistant 服务URL (例如: "https://api.us-south.assistant.watson.cloud.ibm.com")
SERVICE_URL="YOUR_WATSONX_ASSISTANT_SERVICE_URL"
# 替换为您的Assistant ID
ASSISTANT_ID="YOUR_ASSISTANT_ID"
# --- 配置信息结束 ---

# 1. 创建会话 (获取session_id)
CREATE_SESSION_RESPONSE=$(curl -s -X POST \
  "${SERVICE_URL}/v2/assistants/${ASSISTANT_ID}/sessions?version=2021-11-27" \
  -H "Authorization: Bearer ${API_KEY}" \
  -H "Content-Type: application/json")

SESSION_ID=$(echo "${CREATE_SESSION_RESPONSE}" | python -c "import sys, json; print(json.load(sys.stdin)['session_id'])")
echo "会话已创建: ${SESSION_ID}"

# 2. 发送消息 (不包含动作ID)
USER_MESSAGE="我想预订一个从北京到上海的航班"
curl -s -X POST \
  "${SERVICE_URL}/v2/assistants/${ASSISTANT_ID}/sessions/${SESSION_ID}/message?version=2021-11-27" \
  -H "Authorization: Bearer ${API_KEY}" \
  -H "Content-Type: application/json" \
  -d "{
    \"input\": {
      \"message_type\": \"text\",
      \"text\": \"${USER_MESSAGE}\"
    }
  }"

# 3. 删除会话 (可选，生产环境中应在会话结束时执行)
# curl -s -X DELETE \
#   "${SERVICE_URL}/v2/assistants/${ASSISTANT_ID}/sessions/${SESSION_ID}?version=2021-11-27" \
#   -H "Authorization: Bearer ${API_KEY}"