Amazon Connectで通話終了直後に、即文字起こし内容を要約してコンタクト詳細に表示する方法

{
	"Version": "2012-10-17",
	"Statement": [
		{
			"Effect": "Allow",
			"Action": "bedrock:InvokeModel",
			"Resource": "*"
		},
		{
			"Effect": "Allow",
			"Action": [
                "connect:ListRealtimeContactAnalysisSegments",
                "connect:UpdateContactAttributes"
            ],
			"Resource": [
				"arn:aws:connect:ap-northeast-1:111111111111:instance/3ff2093d-af96-43fd-b038-3c07cdd7609c",
				"arn:aws:connect:ap-northeast-1:111111111111:instance/3ff2093d-af96-43fd-b038-3c07cdd7609c/contact/*"
			]
		},
		{
			"Effect": "Allow",
			"Action": [
				"logs:CreateLogGroup",
				"logs:CreateLogStream",
				"logs:PutLogEvents"
			],
			"Resource": "arn:aws:logs:*:*:*"
		}
	]
}

import boto3
import json
import time
from datetime import timezone, timedelta

# 定数定義
MODEL_ID = 'apac.amazon.nova-pro-v1:0'
JST = timezone(timedelta(hours=9))
MAX_RESULTS = 100
SLEEP_SECONDS = 1

# AWSクライアント初期化
connect_lens = boto3.client('connect-contact-lens')
connect_client = boto3.client('connect')
bedrock_client = boto3.client('bedrock-runtime')

def validate_and_extract_ids(detail: dict) -> (str, str):
    """
    event.detail から contactId と instanceId を検証して取得する。
    instanceArn からインスタンスIDを抽出。
    contactId または instanceArn がなければエラーを投げる。
    """
    contact_id = detail.get('contactId')
    instance_arn = detail.get('instanceArn')
    if not contact_id:
        raise ValueError("Missing contactId in event.detail")
    if not instance_arn:
        raise ValueError("Missing instanceArn in event.detail")
    try:
        instance_id = instance_arn.split(":")[-1].split("/")[-1]
    except Exception:
        raise ValueError(f"Invalid instanceArn format: {instance_arn}")
    return contact_id, instance_id

def fetch_transcripts(instance_id: str, contact_id: str) -> list[dict]:
    """
    Connect Lens を使ってすべてのリアルタイム文字起こしのセグメントを取得。
    発言者と内容のリストを返す。
    失敗時には例外を投げる。
    """
    transcripts = []
    next_token = None

    while True:
        params = {
            'InstanceId': instance_id,
            'ContactId': contact_id,
            'MaxResults': MAX_RESULTS
        }
        if next_token:
            params['NextToken'] = next_token

        try:
            resp = connect_lens.list_realtime_contact_analysis_segments(**params)
        except Exception as e:
            raise RuntimeError(f"Failed to list realtime segments: {e}")

        segments = resp.get('Segments', [])
        print(f"Fetched {len(segments)} segments")

        for seg in segments:
            t = seg.get('Transcript')
            if t and 'Content' in t:
                content = t['Content'].strip()
                participant = t.get('ParticipantRole', 'UNKNOWN')
                if content:
                    transcripts.append({'participant': participant, 'content': content})

        next_token = resp.get('NextToken')
        if not next_token:
            break
        time.sleep(SLEEP_SECONDS)

    return transcripts

def create_summary_and_update(instance_id: str, contact_id: str, full_text: str) -> str:
    """
    full_text をベースに要約を生成し、Connect の contact attributes に保存する。
    成功時には要約文字列を返す。
    """
    # 最小限スタイルのプロンプト
    prompt = f"""
通話記録の要約をお願いします。

通話内容:
{full_text}

要約内容:
1. 顧客の問い合わせ内容
2. エージェントの対応内容
3. 結論（解決・今後の対応など）

制約:
- 通話内容に忠実であること
- 推測はしないこと
- 具体的な情報（日付、注文番号など）は明記すること

出力形式:
- 3～4 文
- 自然な文章
- 前置きなし、要約のみ
"""

    try:
        resp = bedrock_client.converse(
            modelId=MODEL_ID,
            messages=[{"role": "user", "content": [{"text": prompt}]}],
            inferenceConfig={"maxTokens": 1000, "temperature": 0.1}
        )
        content_list = resp['output']['message']['content']
        if not content_list or len(content_list) == 0:
            raise RuntimeError("Bedrock response has no content")
        summary = content_list[0].get('text', '').strip()
    except Exception as e:
        raise RuntimeError(f"Failed to generate summary: {e}")

    try:
        connect_client.update_contact_attributes(
            InstanceId=instance_id,
            InitialContactId=contact_id,
            Attributes={'realtimesummary': summary}
        )
    except Exception as e:
        raise RuntimeError(f"Failed to update contact attributes: {e}")

    return summary

def lambda_handler(event, context):
    print('Event Received: ' + json.dumps(event, ensure_ascii=False))

    try:
        detail = event.get('detail', {})
        contact_id, instance_id = validate_and_extract_ids(detail)

        print(f"ContactId={contact_id}, InstanceId={instance_id}")

        transcripts = fetch_transcripts(instance_id, contact_id)
        if not transcripts:
            print("No transcript segments found.")
            return {'statusCode': 200, 'body': 'No transcript to summarize'}

        full_text = "\n".join(f"[{t['participant']}] {t['content']}" for t in transcripts)
        print("Transcript:\n" + full_text)

        summary = create_summary_and_update(instance_id, contact_id, full_text)
        print("Generated and updated summary: " + summary)

        return {
            'statusCode': 200,
            'body': {
                'contact_id': contact_id,
                'realtimesummary': summary
            }
        }

    except ValueError as ve:
        print(f"Input validation error: {ve}")
        return {'statusCode': 400, 'body': str(ve)}
    except RuntimeError as re:
        print(f"Processing error: {re}")
        return {'statusCode': 500, 'body': str(re)}
    except Exception as e:
        print(f"Unexpected error: {e}")
        return {'statusCode': 500, 'body': f"Internal error: {e}"}

{
  "source": ["aws.connect"],
  "detail-type": ["Amazon Connect Contact Event"],
  "detail": {
    "eventType": ["DISCONNECTED"],
    "channel": ["VOICE"],
    "instanceArn": ["arn:aws:connect:ap-northeast-1:111111111111:instance/3ff2093d-af96-43fd-b038-3c07cdd7609c"]
  }
}

会話内容は以下のとおりです。

Customer：実は、ウェブサイトにログインしようとしたんですが、パスワードを受け取ったメールのリンクをクリックしても、「リンクが無効です」というエラーが出るんです。

Agent：それはご不便をおかけして申し訳ありません。どのメールプロバイダーをご利用でしょうか？

Customer：Gmail です。

Agent：ありがとうございます。リンクを開く際に、ブラウザを変えてみたり、別のデバイスで試すことはされましたか？また、リンクが届いたメールが古い可能性もあります。

Customer：はい、スマホとパソコン両方で試しましたが、同じエラーが出ます。メールは15分前に届いたものです。

Agent：承知しました。それではこちらでパスワードリセットリンクを再発行いたします。新しいリンクをお送りしますので、届き次第クリックしていただけますか？

Customer：はい、お願いします。

Agent：新しいリンクを送りました。届いたメールのリンクをクリックしてみてください。

Customer：…わかりました、開いてみます。あ、今、ログインできました！ありがとうございます！