【Amazon Connect】録音ファイルを指定した電話番号に発信して再生する「録音転送システム」を作ってみた

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Sid": "AllowConnectPlayPrompt",
            "Effect": "Allow",
            "Principal": {
                "Service": "connect.amazonaws.com"
            },
            "Action": [
                "s3:ListBucket",
                "s3:GetObject"
            ],
            "Resource": [
                "arn:aws:s3:::<S3バケット名>",
                "arn:aws:s3:::<S3バケット名>/*"
            ]
        }
    ]
}

(レイヤーのARNの例)
arn:aws:lambda:<AWSリージョン>:<AWSアカウントID>:layer:ffmpeg:<バージョン>

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "s3:GetObject",
                "s3:PutObject"
            ],
            "Resource": "arn:aws:s3:::*/*"
        }
    ]
}

(ARNの例)
arn:aws:lambda:<AWSリージョン>:<AWSアカウントID>:layer:ffmpeg:<バージョン>

import subprocess
import urllib.parse
import boto3

s3 = boto3.client("s3")

# /opt/bin はLambdaレイヤーのffmpegパス
FFMPEG_PATH = "/opt/bin/ffmpeg"
# 変換後ファイルの出力先バケット
OUTPUT_BUCKET = "<出力先S3バケット名>"

def lambda_handler(event, context):
    """
    S3上のWAVファイル(PCM/ステレオ)をU-Law/モノラルに変換し、別バケットに保存する
    """
    # S3トリガーイベントからバケット名とキーを取得
    record = event["Records"][0]["s3"]
    source_bucket = record["bucket"]["name"]
    key = urllib.parse.unquote_plus(record["object"]["key"])

    # 一時ファイルパス
    input_path = "/tmp/input.wav"
    output_path = "/tmp/output.wav"

    # 元バケットからダウンロード
    s3.download_file(source_bucket, key, input_path)

    # ffmpegで変換: 8KHz, モノラル, U-Law
    cmd = [
        FFMPEG_PATH,
        "-y",
        "-i", input_path,
        "-ar", "8000",
        "-ac", "1",
        "-acodec", "pcm_mulaw",
        output_path,
    ]

    result = subprocess.run(cmd, capture_output=True, text=True, timeout=30)

    if result.returncode != 0:
        raise RuntimeError(f"ffmpeg failed: {result.stderr}")

    # 変換後のキー: converted/ プレフィックスに保存
    converted_key = key.replace("CallRecordings/", "CallRecordings/converted/")

    # 出力先バケットにアップロード
    s3.upload_file(
        output_path,
        OUTPUT_BUCKET,
        converted_key,
        ExtraArgs={"ContentType": "audio/wav"},
    )

    # PlayPrompt用のHTTPS URL生成
    encoded_key = urllib.parse.quote(converted_key, safe="/")
    converted_url = f"https://{OUTPUT_BUCKET}.s3.ap-northeast-1.amazonaws.com/{encoded_key}"

    return {
        "convertedUrl": converted_url,
        "convertedBucket": OUTPUT_BUCKET,
        "convertedKey": converted_key,
    }

{
  "Comment": "録音転送システム",
  "StartAt": "Amazon Connect 発信",
  "States": {
    "Amazon Connect 発信": {
      "Type": "Task",
      "Resource": "arn:aws:states:::aws-sdk:connect:startOutboundVoiceContact",
      "Parameters": {
        "InstanceId": "<AmazonConnectインスタンスID>",
        "ContactFlowId": "<AmazonConnectフローID>",
        "SourcePhoneNumber": "<AmazonConnect電話番号>",
        "DestinationPhoneNumber": "<転送先電話番号>",
        "Attributes": {
          "s3file.$": "$.s3file"
        }
      },
      "End": true
    }
  }
}

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": "connect:StartOutboundVoiceContact",
            "Resource": "arn:aws:connect:ap-northeast-1:<AWSアカウントID>:instance/*/contact/*"
        }
    ]
}

{
  "source": ["aws.s3"],
  "detail-type": ["Object Created"],
  "detail": {
    "bucket": {
      "name": ["<S3バケット名>"]
    },
    "object": {
      "key": [{
        "wildcard": "connect/<S3バケット名>/CallRecordings/*.wav"
      }]
    }
  }
}

{
  "bucket": "$.detail.bucket.name",
  "key": "$.detail.object.key"
}

{
  "s3file": "https://<bucket>.s3.ap-northeast-1.amazonaws.com/<key>"
}