AWS Step FunctionsでAmazon Connectの通話会話内容を要約し、Backlogのコメントに自動追加してみた

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "s3:GetObject"
            ],
            "Resource": [
                "arn:aws:s3:::amazon-connect-xxxxxxxxxx/Analysis/Voice/*"
            ]
        }
    ]
}

{
  "Comment": "Amazon Connect 会話要約ワークフロー",
  "StartAt": "GetTranscriptFromS3",
  "QueryLanguage": "JSONata",
  "States": {
    "GetTranscriptFromS3": {
      "Type": "Task",
      "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) %}"
      },
      "Next": "ExtractTranscriptText"
    },
    "ExtractTranscriptText": {
      "Type": "Pass",
      "Assign": {
        "transcriptText": "{% $join($map($transcriptData.Transcript,function($t){'[' & ($t.ParticipantId = 'AGENT' ? 'AGENT' : 'CUSTOMER') & ']' & $t.Content}),' ')%}",
        "contactId": "{% $transcriptData.CustomerMetadata.ContactId %}"
      },
      "Next": "CheckTranscriptText"
    },
    "CheckTranscriptText": {
      "Type": "Choice",
      "Choices": [
        {
          "Condition": "{% $length($transcriptText) > 0 %}",
          "Next": "GenerateSummary"
        }
      ],
      "Default": "NoTranscriptFound"
    },
    "NoTranscriptFound": {
      "Type": "Fail",
      "Error": "NoTranscriptFound",
      "Cause": "No transcript text found in the file."
    },
    "GenerateSummary": {
      "Type": "Task",
      "Resource": "arn:aws:states:::bedrock:invokeModel",
      "Arguments": {
        "ModelId": "anthropic.claude-3-5-sonnet-20240620-v1:0",
        "ContentType": "application/json",
        "Accept": "application/json",
        "Body": {
          "anthropic_version": "bedrock-2023-05-31",
          "max_tokens": 1000,
          "temperature": 0.5,
          "messages": [
            {
              "role": "user",
              "content": [
                {
                  "type": "text",
                  "text": "{% '以下の通話内容を要約してください。\n\n【要約のフォーマット】\n1. 問い合わせ概要：顧客が何について問い合わせたか、簡潔に記載\n2. 詳細確認：エージェントがどのような情報を確認したか\n3. 対応内容：エージェントがどのように対応したか\n4. 結果：最終的な解決策や顧客の反応\n\n【通話内容】\n' & $transcriptText & '\n\n【出力のルール】\n- 「要約: 」で始め、一段落の自然な文章で記述する\n- 重要な情報（日付、注文番号、金額など）は具体的に含める\n- 専門用語や略語は避け、誰にでも分かりやすい表現を使用する\n- 顧客の感情の変化（不安→安心など）も可能な限り含める\n- 全体で100〜200文字程度に収める\n- 「まもなく解決予定」「対応完了」など、明確な結論で締めくくる\n\n【出力例】\n要約: 顧客が先週購入したヘッドフォン（注文番号BT-2023）の不具合について問い合わせ。エージェントは購入履歴と保証内容を確認し、製品が保証期間内であることを確認。無償交換または返金の選択肢を提案し、顧客は返金を希望。エージェントは返金手続きを開始し、5営業日以内に全額が返金される予定と案内。顧客は対応の迅速さに満足し、手続き完了。' %}"
                }
              ]
            }
          ]
        }
      },
      "Assign": {
        "summary": "{% $states.result.Body.content[type=\"text\"].text %}"
      },
      "Next": "GetBacklogIssueKey"
    },
    "GetBacklogIssueKey": {
      "Type": "Task",
      "Resource": "arn:aws:states:::dynamodb:getItem",
      "Arguments": {
        "TableName": "cm-hirai-connect-backlog-tracker",
        "Key": {
          "contact_id": {
            "S": "{% $contactId %}"
          }
        }
      },
      "Assign": {
        "backlogIssueKey": "{% $states.result.Item.backlog_issue_id.S %}"
      },
      "Next": "UpdateBacklogIssueComment"
    },
    "UpdateBacklogIssueComment": {
      "Type": "Task",
      "Resource": "arn:aws:states:::http:invoke",
      "Arguments": {
        "ApiEndpoint": "{% 'https://<xxx.backlog.jp>/api/v2/issues/' & $backlogIssueKey %}",
        "Method": "PATCH",
        "InvocationConfig": {
          "ConnectionArn": "<ConnectionArn>"
        },
        "RequestBody": {
          "comment": "{% $summary %}"
        }
      },
      "Retry": [
        {
          "ErrorEquals": [
            "States.ALL"
          ],
          "BackoffRate": 2,
          "IntervalSeconds": 1,
          "MaxAttempts": 3,
          "JitterStrategy": "FULL"
        }
      ],
      "End": true
    }
  }
}

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

【要約のフォーマット】
1. 問い合わせ概要：顧客が何について問い合わせたか、簡潔に記載
2. 詳細確認：エージェントがどのような情報を確認したか
3. 対応内容：エージェントがどのように対応したか
4. 結果：最終的な解決策や顧客の反応

【通話内容】
 & $transcriptText & 

【出力のルール】
- 「要約: 」で始め、一段落の自然な文章で記述する
- 重要な情報（日付、注文番号、金額など）は具体的に含める
- 専門用語や略語は避け、誰にでも分かりやすい表現を使用する
- 顧客の感情の変化（不安→安心など）も可能な限り含める
- 全体で100〜200文字程度に収める
- 「まもなく解決予定」「対応完了」など、明確な結論で締めくくる

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

{
  "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/"
      }, {
        "suffix": ".json"
      }]
    }
  }
}

{
  "detail-type": "AWS API Call via CloudTrail",
  "source": "aws.s3",
  "account": "111111111111",
  "time": "2025-04-24T00:17:16Z",
  "region": "ap-northeast-1",
  "resources": [],
  "detail": {
    "eventTime": "2025-04-24T00:17:16Z",
    "eventSource": "s3.amazonaws.com",
    "eventName": "PutObject",
    "awsRegion": "ap-northeast-1",
    "requestParameters": {
      "bucketName": "amazon-connect-xxxxxxxxxx",
      "key": "Analysis/Voice/2025/04/24/aa165854-149e-460f-94b3-facf03ae934e_analysis_2025-04-24T02_47_18Z.json",
    },
    "readOnly": false,
    "resources": [
      {
        "type": "AWS::S3::Object",
        "ARN": "arn:aws:s3:::amazon-connect-xxxxxxxxxx/Analysis/Voice/2025/04/24/aa165854-149e-460f-94b3-facf03ae934e_analysis_2025-04-24T02_47_18Z.json"
      },
      {
        "accountId": "111111111111",
        "type": "AWS::S3::Bucket",
        "ARN": "arn:aws:s3:::amazon-connect-xxxxxxxxxx"
      }
    ],
    "eventType": "AwsApiCall"
  }
}