テキストを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認定デベロッパーアソシエイト［DVA-C02対応］」という本を書きました。

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

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

@yamamanx

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

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

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

- AWS AWS, lambda, polly, s3

: S3オブジェクトロックを試しました

S3オブジェクトロックが必要になる要件に今のところ、出会ってないのでまだ設定した …

: AWS Backupで取得したAMIとスナップショットの削除

個人で使っているAWSリソースの断捨離をしてました。 Cloud9も複数アカウン …

: S3バケットのデフォルト暗号化はデフォルトだったことを確認しました

S3バケットのデフォルト暗号化は名前のとおりだとデフォルトなので、暗号化を指定し …

: ヤマムギvol.26 Amazon DynamoDBのデモをしました

今日はAWS認定クラウドプラクティショナー対策本(緑本)に関係するデモをしました …

: AWS Savings Plansを検討しました

今、個人でAWSアカウントを７つ使っています。 Savings Plansが使え …

: SageMaker AI StudioでJupyterLab スペースを作成しJupyterLab を起動、S3拡張のインストール

JupyterLab ユーザーガイドとJupyterLab 拡張機能を参照して、 …

: 「関西AWSスタートアップ勉強会」に行ってきました

第2回関西スタートアップAWS勉強会に行ってきました。 akippa 拠点数コ …

: [JapanTaxi] Athena 指向アナリティクス〜真面目に手を抜き価値を得よ〜(AWS Summit Tokyo 2017)を聞いてきました

Athenaのユースケースとして聞きにいきましたが、最近触ってるRe:dashも …

: AWS CloudWatch LogsエージェントでAmazon EC2上のNginxのaccess.log , error.log , php-fpm error.log , Linuxのmessages , secureログを収集する

参考ページクイックスタート: 実行中の EC2 インスタンスに CloudWa …

: Lambda関数で自分自身の環境変数を更新する

Twitterでツイート検索するAPIを試してみるでツイートの取得を重複させない …

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