テキストをAmazon PollyでMP3に変換してS3に格納(AWS Lambda Python)

2017/05/06

Google Calendar Twilio ReminderのテキストをAmazon Pollyを使ってMP3ファイルに変換してS3に格納する部分の説明です。

AWS側の設定

MP3格納用S3バケット作成

Pollyのためというよりも後でTwilioでアクセスするための設定です。

Static website hostingを有効にします。

バケットポリシーを作成します。

{
    "Version": "2008-10-17",
    "Statement": [
        {
            "Sid": "PublicReadForGetBucketObjects",
            "Effect": "Allow",
            "Principal": {
                "AWS": "*"
            },
            "Action": "s3:GetObject",
            "Resource": "arn:aws:s3:::bucket_name/*"
        }
    ]
}

{

"Version": "2008-10-17",

"Statement": [

{

"Sid": "PublicReadForGetBucketObjects",

"Effect": "Allow",

"Principal": {

"AWS": "*"

"Action": "s3:GetObject",

"Resource": "arn:aws:s3:::bucket_name/*"

}

]

}

ライフサイクルを設定します

生成されたMP3ファイルは不要になるのでライフサイクルルールで削除します。

Lambda実行用ロールの作成

ここで作ったロールをLambdaに設定します。

雑ですが、管理ポリシーに以下を設定しました。

AWSLambdaFullAccess
AmazonS3FullAccess
AmazonPollyFullAccess

あと、インラインポリシーに下記を設定しました。
これがないとログが出力されませんでした。

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "logs:CreateLogGroup",
                "logs:CreateLogStream",
                "logs:PutLogEvents"
            ],
            "Resource": "arn:aws:logs:*:*:*"
        }
    ]
}

{

"Version": "2012-10-17",

"Statement": [

{

"Effect": "Allow",

"Action": [

"logs:CreateLogGroup",

"logs:CreateLogStream",

"logs:PutLogEvents"

"Resource": "arn:aws:logs:*:*:*"

}

]

}

AWS Lambdaの環境変数

変数名	設定値
BUCKET_NAME	Amazon Pollyが生成するMP3ファイルを格納するS3バケット名
BUCKET_REGION	ap-northeast-1など S3バケットがあるリージョン名
VOICE_ID	Amazon PollyのボイスID 日本語なので Mizuki
POLLY_REGION	Amazon Pollyのリージョン名

ソースコードの説明

AWSのサンプルコードをベースにして少し変えてます。

# coding:utf-8

import os
import logging
import sys
import traceback
from boto3 import Session
from boto3 import resource
from contextlib import closing

logger = logging.getLogger()
logger.setLevel(logging.INFO)

class PollyMp3(object):

    def __init__(self):
        self.polly_region = os.environ['POLLY_REGION']
        self.bucket_name = os.environ['BUCKET_NAME']
        self.bucket_region = os.environ['BUCKET_REGION']
        self.voice_id = os.environ['VOICE_ID']

    def set_twiml(self,file_name,twiml_str):
        try:
            s3 = resource('s3')
            bucket = s3.Bucket(self.bucket_name)

            twiml_file_name = '%s.xml' % file_name

            bucket.put_object(
                Key=twiml_file_name,
                Body=twiml_str,
                ContentType='application/xml'
            )

            ENTRY_URL = "https://s3-{region}.amazonaws.com/{bucket}/{filename}"
            entry_url = ENTRY_URL.format(
                bucket=self.bucket_name,
                region=self.bucket_region,
                filename=twiml_file_name
            )

            return entry_url

        except Exception as e:
            logger.error(traceback.format_exc(sys.exc_info()[2]))

    def set_mp3(self,file_name,polly_text):
        try:
            session = Session(region_name=self.polly_region)
            polly = session.client("polly")
            s3 = resource('s3')
            bucket = s3.Bucket(self.bucket_name)

            response = polly.synthesize_speech(
                Text=polly_text,
                OutputFormat="mp3",
                VoiceId=self.voice_id)

            mp3_file_name = '%s.mp3' % file_name

            with closing(response["AudioStream"]) as stream:
                bucket.put_object(
                    Key=mp3_file_name,
                    Body=stream.read(),
                    ContentType = 'audio/mpeg'
                )

            ENTRY_URL = "https://s3-{region}.amazonaws.com/{bucket}/{filename}"
            entry_url = ENTRY_URL.format(
                bucket=self.bucket_name,
                region=self.bucket_region,
                filename=mp3_file_name
            )

            return entry_url

        except Exception as e:
            logger.error(traceback.format_exc(sys.exc_info()[2]))

# coding:utf-8

import os

import logging

import sys

import traceback

from boto3 import Session

from boto3 import resource

from contextlib import closing

logger = logging.getLogger()

logger.setLevel(logging.INFO)

class PollyMp3(object):

def __init__(self):

self.polly_region = os.environ['POLLY_REGION']

self.bucket_name = os.environ['BUCKET_NAME']

self.bucket_region = os.environ['BUCKET_REGION']

self.voice_id = os.environ['VOICE_ID']

def set_twiml(self,file_name,twiml_str):

try:

s3 = resource('s3')

bucket = s3.Bucket(self.bucket_name)

twiml_file_name = '%s.xml' % file_name

bucket.put_object(

Key=twiml_file_name,

Body=twiml_str,

ContentType='application/xml'

)

ENTRY_URL = "https://s3-{region}.amazonaws.com/{bucket}/{filename}"

entry_url = ENTRY_URL.format(

bucket=self.bucket_name,

region=self.bucket_region,

filename=twiml_file_name

)

return entry_url

except Exception as e:

logger.error(traceback.format_exc(sys.exc_info()[2]))

def set_mp3(self,file_name,polly_text):

try:

session = Session(region_name=self.polly_region)

polly = session.client("polly")

s3 = resource('s3')

bucket = s3.Bucket(self.bucket_name)

response = polly.synthesize_speech(

Text=polly_text,

OutputFormat="mp3",

VoiceId=self.voice_id)

mp3_file_name = '%s.mp3' % file_name

with closing(response["AudioStream"]) as stream:

bucket.put_object(

Key=mp3_file_name,

Body=stream.read(),

ContentType = 'audio/mpeg'

)

ENTRY_URL = "https://s3-{region}.amazonaws.com/{bucket}/{filename}"

entry_url = ENTRY_URL.format(

bucket=self.bucket_name,

region=self.bucket_region,

filename=mp3_file_name

)

return entry_url

except Exception as e:

logger.error(traceback.format_exc(sys.exc_info()[2]))

set_twiml

Twilioを実行するためのTwiml(Twilio独自のXML)をS3に格納しています。
ContentType=’application/xml’ がないとTwilioが認識出来ません。

set_mp3

PollyがテキストをMP3ファイルに変換してS3に格納しています。
synthesize_speech　にテキストを渡して変換結果を受け取っています。
response[“AudioStream”]をput_objectでS3にContentType = ‘audio/mpeg’で書き込んでいます。

最後までお読みいただきましてありがとうございました！

「AWS認定資格試験テキスト＆問題集　AWS認定ソリューションアーキテクト - プロフェッショナル改訂第2版」という本を書きました。

「AWS認定資格試験テキスト AWS認定クラウドプラクティショナー改訂第3版」という本を書きました。

「AWS認定資格試験テキスト　AWS認定AIプラクティショナー」という本を書きました。

「AWS教科書 AWS認定デベロッパーアソシエイトテキスト＆問題集」という本を書きました。

「要点整理から攻略するAWS認定ソリューションアーキテクト-アソシエイト」という本を書きました。

「AWSではじめるLinux入門ガイド」という本を書きました。

@yamamanx

開発ベンダー5年、ユーザ企業システム部門通算9年、ITインストラクター5年目でプロトタイプビルダーもやりだしたSoftware Engineerです。
質問はコメントかSNSなどからお気軽にどうぞ。
出来る限りなるべく答えます。

このブログの内容/発言の一切は個人の見解であり、所属する組織とは関係ありません。
このブログは経験したことなどの共有を目的としており、手順や結果などを保証するものではありません。
ご参考にされる際は、読者様自身のご判断にてご対応をお願いいたします。

また、勉強会やイベントのレポートは自分が気になったことをメモしたり、聞いて思ったことを書いていますので、登壇者の意見や発表内容ではありません。

- AWS AWS, lambda, polly, s3

: EC2 Windows インスタンス PowerShellでメタデータを見る

Linuxインスタンスならcurlコマンドで確認すればいいのですが、Window …

: ヤマムギ vol.8 (AWS)EC2でLinuxサーバー構築ハンズオン手順

ヤマムギとは from Mitsuhiro Yamashita 「AWSではじめ …

: AWS Well-Architected フレームワークによるクラウドベストプラクティスのセッションを聞いたので自アカウントの環境を確認してみる

AWS Summit Tokyo 2017で「AWS Well-Architec …

: ChatGPT APIをTeamsボットから使いました(AWS Lambda(Python) + API Gateway)

ChatGPT APIが有償で利用可能になったので、会社のTeamsボットに実装 …

: 「AWS認定試験対策 AWS クラウドプラクティショナー」の出版が確定したのでAmazon著者セントラルに登録した

初の執筆本、「AWS認定試験対策 AWS クラウドプラクティショナー」の出版が確 …

: AWS Systems Manager セッションマネージャを使用するために必要な設定

AWS Systems Manager セッションマネージャを使用するために必要 …

: kintoneに登録されたアカウントの電話番号にGoogleカレンダーの予定をAmazon Pollyが読み上げてTwilioから電話でお知らせする(AWS Lambda Python)

Google Calendar Twilio Reminder Googleカレ …

: AWS Lambda KMSを使って環境変数を暗号化、復号化する(Python)

Lambda内で外部APIを使用する場合などをユースケースとして、環境変数をKM …

: AWS Organizationsからアカウントを新規作成してみて

AWS Organizationsでアカウントを新規作成することがありましたので …

: AWS Network Firewallの入門

公式のGetting started with AWS Network Fire …

PREV: 個人のGoogleカレンダーの予定をPythonで取得する
NEXT: S3に置いたMP3ファイルをTwilioから電話再生する(AWS Lambda Python)