サーバーレスな郵便番号検索APIを作成してみた #AWS

概要

AWSでサーバーレスな郵便番号検索をつくってみたの手順書です。
ファイルを置いて、プログラムを少し書くだけ簡単にできます。

必要なもの

AWSアカウント

利用するサービス

・　S３　：　郵便番号のCSVを格納

・　S３ Select　：　S3のデータをSQLライクに抽出する

・　Lambda　：　S3のCSVからレスポンスを返すメソッド

・　API GetWay　：　Lambdaの内容をAPI化する

Step1:郵便局のCSVダウンロード

日本郵政のページから以下CSVをダウンロード。
文字コードがShiftJISなので、UTF8に変換しておく。

またSQLをわかりやすくかけるように、以下のヘッダーを付与する。

JISCode,OldPostCode,PostCode,PrefecturesNameKana,CityNameKana,TownNameKana,PrefecturesName,CityName,TownName,Note1,Note2,Note3,Note4,Note5,Note6

Step２:S3にCSVデータをアップロード

バケットを作成の上、対象のCSVファイルをアップロード

Step3:S3 Selectを試してみる

S3 Selectタブ選択して、画面下の次へを押す。

SQLが入力できることを確認

Step４:Lambdaを作成

　・言語はPython

　・作成後、IMAロールにS3の読み取り権限を付与する

　・　対象のロールからS3ReadOnlyAccessを付与する

　・　ソースコードは以下にて作成

import boto3

BUCKET_NAME = 'XXXXXX'
OBJECT_KEY = 'XXXXXX.CSV'
COMPRESSION_TYPE = 'NONE'

def lambda_handler(event, context):
    # APIのパラメーター
    postcode = event['postcode']
    # S3 Select
    query = 'select * from s3object s where PostCode =\'' + postcode + '\''
    s3 = boto3.client('s3')

    #S3.Client.select_object_contentの設定
    response = s3.select_object_content(
        Bucket=BUCKET_NAME,
        Key=OBJECT_KEY,
        ExpressionType='SQL',
        Expression=query,
        InputSerialization={
            'CSV': {
                'FileHeaderInfo': 'USE',
                'RecordDelimiter': '\n',
                'FieldDelimiter': ',',
            },
            'CompressionType': COMPRESSION_TYPE,
        },
        OutputSerialization={
            'JSON': {
                'RecordDelimiter': '\n'
            }
        }
    )

    # 結果を表示
    for payload in response['Payload']:
        if 'Records' in payload:
            records = payload['Records']['Payload']
            return records