Amazon Connectコンタクト検索の制限を解決し、コンタクトごとの会話履歴をDynamoDBに自動保存・CSV形式で一括エクスポートできるようにしてみた

aws dynamodb create-table \
    --table-name cm-hirai-connect-contacts \
    --attribute-definitions \
        AttributeName=contact_id,AttributeType=S \
    --key-schema \
        AttributeName=contact_id,KeyType=HASH \
    --billing-mode PAY_PER_REQUEST \
    --region ap-northeast-1

{
  "Comment": "Amazon Connect会話履歴をDynamoDBに保存するワークフロー - 改善版",
  "StartAt": "DefineConstants",
  "QueryLanguage": "JSONata",
  "States": {
    "DefineConstants": {
      "Type": "Pass",
      "Comment": "ワークフローで使用する定数を定義。インスタンス情報、DynamoDB、Bedrockの設定値を一元管理",
      "Assign": {
        "instanceId": "xxxxx",
        "instanceAlias": "xxxx",
        "dynamodbTable": "cm-hirai-connect-contacts",
        "bedrockModel": "anthropic.claude-3-5-sonnet-20240620-v1:0",
        "ttlDays": 30,
        "maxTokens": 1000,
        "temperature": 0.5,
        "timezone": "Asia/Tokyo"
      },
      "Next": "GetTranscriptFromS3"
    },
    "GetTranscriptFromS3": {
      "Type": "Task",
      "Comment": "EventBridgeから受信したS3イベント情報を使用して、文字起こしJSONファイルをS3から取得",
      "Resource": "arn:aws:states:::aws-sdk:s3:getObject",
      "Arguments": {
        "Bucket": "{% $states.context.Execution.Input.detail.requestParameters.bucketName %}",
        "Key": "{% $states.context.Execution.Input.detail.requestParameters.key %}"
      },
      "Assign": {
        "transcriptData": "{% $parse($states.result.Body) %}",
        "s3Key": "{% $states.context.Execution.Input.detail.requestParameters.key %}"
      },
      "Next": "ExtractContactIdAndTranscript"
    },
    "ExtractContactIdAndTranscript": {
      "Type": "Pass",
      "Comment": "S3キーからContactIDを抽出し、JSONから会話内容を整形。Connect詳細画面のURLも生成",
      "Assign": {
        "contactId": "{% $substringBefore($split($s3Key, '/')[-1], '_analysis') %}",
        "transcriptText": "{% $join($map($transcriptData.Transcript,function($t){'[' & ($t.ParticipantId = 'AGENT' ? 'AGENT' : 'CUSTOMER') & ']' & $t.Content}),' ') %}",
        "contactUrl": "{% 'https://' & $instanceAlias & '.my.connect.aws/contact-trace-records/details/' & $substringBefore($split($s3Key, '/')[-1], '_analysis') & '?tz=' & $timezone %}"
      },
      "Next": "CheckTranscriptText"
    },
    "CheckTranscriptText": {
      "Type": "Choice",
      "Comment": "文字起こしテキストが存在するかチェック。空の場合は処理を中断してエラーとする",
      "Choices": [
        {
          "Condition": "{% $length($transcriptText) > 0 %}",
          "Next": "GetContactDetails"
        }
      ],
      "Default": "NoTranscriptFound"
    },
    "NoTranscriptFound": {
      "Type": "Fail",
      "Comment": "文字起こしテキストが見つからない場合のエラー終了",
      "Error": "NoTranscriptFound",
      "Cause": "No transcript text found in the file."
    },
    "GetContactDetails": {
      "Type": "Task",
      "Comment": "Amazon Connect APIを使用してコンタクト詳細情報を取得。発信者番号、対応日時、エージェント名を取得",
      "Resource": "arn:aws:states:::aws-sdk:connect:describeContact",
      "Arguments": {
        "InstanceId": "{% $instanceId %}",
        "ContactId": "{% $contactId %}"
      },
      "Assign": {
        "callerPhoneNumber": "{% $states.result.Contact.CustomerEndpoint.Address %}",
        "contactDateTime": "{% $states.result.Contact.InitiationTimestamp %}",
        "agentName": "{% $states.result.Contact.Attributes.Agent ? $states.result.Contact.Attributes.Agent : 'Unknown' %}"
      },
      "Next": "GenerateSummary"
    },
    "GenerateSummary": {
      "Type": "Task",
      "Comment": "Amazon Bedrock（Claude）を使用して会話内容の日本語要約を生成。文字数制限を適用して長すぎる文字起こしを制限",
      "Resource": "arn:aws:states:::bedrock:invokeModel",
      "Arguments": {
        "ModelId": "{% $bedrockModel %}",
        "ContentType": "application/json",
        "Accept": "application/json",
        "Body": {
          "anthropic_version": "bedrock-2023-05-31",
          "max_tokens": "{% $maxTokens %}",
          "temperature": "{% $temperature %}",
          "messages": [
            {
              "role": "user",
              "content": [
                {
                  "type": "text",
                  "text": "{% '以下の通話内容を要約してください。\n\n【通話内容】\n' & $substring($transcriptText, 0, 4000) & '\n\n【要約時に含める要素】\n- 問い合わせ概要：顧客が何について問い合わせたか\n- 詳細確認：エージェントがどのような情報を確認したか\n- 対応内容：エージェントがどのように対応したか\n- 結果：最終的な解決策や顧客の反応\n\n【出力のルール】\n- 前置きや説明文は不要。要約文のみを出力する\n- 重要な情報（日付、注文番号、金額など）は具体的に含める\n- 専門用語や略語は避け、誰にでも分かりやすい表現を使用する\n- 顧客の感情の変化（不安→安心など）も可能な限り含める\n- 全体で100〜200文字程度に収める\n- 「まもなく解決予定」「対応完了」など、明確な結論で締めくくる\n- 挨拶のみや要約に値する内容がない場合は「要約対象となる具体的な問い合わせ内容がありませんでした。」と出力する\n\n【出力例】\n顧客が先週購入したヘッドフォン（注文番号A-1）の不具合について問い合わせ。エージェントは購入履歴と保証内容を確認し、製品が保証期間内であることを確認。無償交換または返金の選択肢を提案し、顧客は返金を希望。エージェントは返金手続きを開始し、5営業日以内に全額が返金される予定と案内。顧客は対応の迅速さに満足し、手続き完了。' %}"
                }
              ]
            }
          ]
        }
      },
      "Assign": {
        "summary": "{% $states.result.Body.content[type=\"text\"].text %}"
      },
      "Next": "CalculateTTL"
    },
    "CalculateTTL": {
      "Type": "Pass",
      "Comment": "DynamoDB TTL用のタイムスタンプを計算。対応日時から指定日数（デフォルト30日）後の値を設定",
      "Assign": {
        "ttlTimestamp": "{% $round($toMillis($contactDateTime) / 1000 + ($ttlDays * 86400)) %}"
      },
      "Next": "SaveToDynamoDB"
    },
    "SaveToDynamoDB": {
      "Type": "Task",
      "Comment": "すべての情報をDynamoDBに保存。コンタクト情報、文字起こし、要約、メタデータを含むレコードを作成",
      "Resource": "arn:aws:states:::aws-sdk:dynamodb:putItem",
      "Arguments": {
        "TableName": "{% $dynamodbTable %}",
        "Item": {
          "contact_id": {
            "S": "{% $contactId %}"
          },
          "caller_phone_number": {
            "S": "{% $callerPhoneNumber %}"
          },
          "transcript": {
            "S": "{% $transcriptText %}"
          },
          "summary": {
            "S": "{% $summary %}"
          },
          "contact_datetime": {
            "S": "{% $string($contactDateTime) %}"
          },
          "agent_name": {
            "S": "{% $agentName %}"
          },
          "contact_url": {
            "S": "{% $contactUrl %}"
          },
          "ttl": {
            "N": "{% $string($ttlTimestamp) %}"
          }
        }
      },
      "End": true
    }
  }
}

以下の通話内容を要約してください。

【通話内容】
' & $substring($transcriptText, 0, 4000) & '

【要約時に含める要素】
- 問い合わせ概要：顧客が何について問い合わせたか
- 詳細確認：エージェントがどのような情報を確認したか
- 対応内容：エージェントがどのように対応したか
- 結果：最終的な解決策や顧客の反応

【出力のルール】
- 前置きや説明文は不要。要約文のみを出力する
- 重要な情報（日付、注文番号、金額など）は具体的に含める
- 専門用語や略語は避け、誰にでも分かりやすい表現を使用する
- 顧客の感情の変化（不安→安心など）も可能な限り含める
- 全体で100〜300文字程度に収める
- 「まもなく解決予定」「対応完了」など、明確な結論で締めくくる
- 挨拶のみや要約に値する内容がない場合は「要約対象となる具体的な問い合わせ内容がありませんでした。」と出力する

【出力例】
顧客が先週購入したヘッドフォン（注文番号A-1）の不具合について問い合わせ。エージェントは購入履歴と保証内容を確認し、製品が保証期間内であることを確認。無償交換または返金の選択肢を提案し、顧客は返金を希望。エージェントは返金手続きを開始し、5営業日以内に全額が返金される予定と案内。顧客は対応の迅速さに満足し、手続き完了。

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "s3:GetObject"
            ],
            "Resource": [
                "arn:aws:s3:::amazon-connect-xxxxxx/Analysis/Voice/*"
            ]
        },
        {
            "Effect": "Allow",
            "Action": [
                "connect:DescribeContact"
            ],
            "Resource": [
                "arn:aws:connect:ap-northeast-1:アカウントID:instance/ConnectインスタンスID/contact/*"
            ]
        }
    ]
}

{
  "source": ["aws.s3"],
  "detail-type": ["AWS API Call via CloudTrail"],
  "detail": {
    "eventSource": ["s3.amazonaws.com"],
    "eventName": ["PutObject"],
    "requestParameters": {
      "bucketName": ["amazon-connect-xxxxxxxxxx"],
      "key": [{
        "prefix": "Analysis/Voice/"
      }]
    }
  }
}

{
  "version": "0",
  "id": "18587533-cc77-def2-7754-ccac36dbd29b",
  "detail-type": "AWS API Call via CloudTrail",
  "source": "aws.s3",
  "account": "アカウントID",
  "time": "2025-04-24T23:43:29Z",
  "region": "ap-northeast-1",
  "resources": [

  ],
  "detail": {
    "eventTime": "2025-04-24T23:43:29Z",
    "eventSource": "s3.amazonaws.com",
    "eventName": "PutObject",
    "awsRegion": "ap-northeast-1",
    "resources": [
      {
        "accountId": "アカウントID",
        "type": "AWS::S3::Bucket",
        "ARN": "arn:aws:s3:::amazon-connect-xxxxxx"
      },
      {
        "type": "AWS::S3::Object",
        "ARN": "arn:aws:s3:::amazon-connect-xxxxxx/Analysis/Voice/2025/04/24/aa165854-149e-460f-94b3-facf03ae934e_analysis_2025-02-13T02_47_18Z (3).json"
      }
    ]
  }
}

{
  "Contact": {
    "AgentInfo": {
    },
    "Attributes": {
      "report": "on",
      "Agent": "hirai"
    },