Python3: Lambda で DynamoDB を使う

こちらのプログラムを Lambda で使えるように書き換えました。
Python3: DynamoDB を使う

city という名前のテーブルを作成

dynamo_create_table.py

#! /usr/bin/python
# -*- coding: utf-8 -*-
#
#   dynamo_create_table.py
#
#               Sep/20/2021
# --------------------------------------------------------------------
import sys
import json
import boto3
#
# --------------------------------------------------------------------
def create_table_proc(name_table):
    dynamodb = boto3.resource('dynamodb')

    table = dynamodb.create_table(
        TableName=name_table,
    KeySchema=[
        {
        'AttributeName': 'key',
        'KeyType': 'HASH'
        },
    ],
    AttributeDefinitions=[
        {
        'AttributeName': 'key',
        'AttributeType': 'S'
        },
    ],
    ProvisionedThroughput={
        'ReadCapacityUnits': 5,
        'WriteCapacityUnits': 5
        }
    )

    print("Table status:", table.table_status)
#
# --------------------------------------------------------------------
def lambda_handler(event, context):
#
    name_table = 'city'
    create_table_proc(name_table)
#
    return {
        'statusCode': 200,
        'body': json.dumps('Hello from Lambda!')
    }

# --------------------------------------------------------------------

データの挿入

dynamo_insert.py

#! /usr/bin/python
# -*- coding: utf-8 -*-
#
#   dynamo_insert.py
#
#                   Sep/20/2021
# ---------------------------------------------------------------
import  sys
import  json
import  boto3
from decimal import *

# ---------------------------------------------------------------
def insert_proc (table,key,name,population,date_mod):
    response = table.put_item ( \
    Item={'key': key,'name': name,'population': population,'date_mod':date_mod}
    )

# ---------------------------------------------------------------
def insert_main_proc(name_table):
    dynamodb = boto3.resource('dynamodb')

    table = dynamodb.Table(name_table)

    insert_proc (table,"t0921","宇都宮",Decimal ("18249"),"2004-2-12")
    insert_proc (table,"t0922","小山",Decimal ("79814"),"2003-5-24")
    insert_proc (table,"t0923","佐野",Decimal ("69826"),"2003-7-17")
    insert_proc (table,"t0924","足利",Decimal ("59123"),"2003-6-28")
    insert_proc (table,"t0925","日光",Decimal ("49521"),"2003-8-29")
    insert_proc (table,"t0926","下野",Decimal ("39427"),"2003-10-14")
#
# ---------------------------------------------------------------
def lambda_handler(event, context):
    name_table = 'city'
    insert_main_proc(name_table)
#
    return {
        'statusCode': 200,
        'body': json.dumps('Hello from Lambda!')
    }
# ---------------------------------------------------------------

データのスキャン

dynamo_scan.py

#! /usr/bin/python
# -*- coding: utf-8 -*-
#
#   dynamo_scan.py
#
#                   Sep/20/2021
# --------------------------------------------------------------------
import  sys
import  json
import  boto3
import  decimal
from boto3.dynamodb.conditions import Key, Attr

# --------------------------------------------------------------------
def scan_proc(name_table):
    dynamodb = boto3.resource('dynamodb')

    table = dynamodb.Table(name_table)

    response = table.scan()

    for it in response['Items']:
        str_out = it['key'] + '\t'
        str_out += it['name'] + '\t'
        str_out += str (it['population']) + '\t'
        str_out += it['date_mod']
        print(str_out)
# --------------------------------------------------------------------
def lambda_handler(event, context):
    name_table = 'city'

    scan_proc(name_table)
#
    return {
        'statusCode': 200,
        'body': json.dumps('Hello from Lambda!')
    }
#
# --------------------------------------------------------------------

キーを指定してデータの取得

dynamo_get.py

#! /usr/bin/python
# -*- coding: utf-8 -*-
#
#   dynamo_get.py
#
#                   Sep/20/2021
# --------------------------------------------------------------------
import sys
import json
import boto3
from boto3.dynamodb.conditions import Key, Attr

# --------------------------------------------------------------------
def get_proc(name_table,key_search):
    dynamodb = boto3.resource('dynamodb')

    table = dynamodb.Table(name_table)

    response = table.query(
        KeyConditionExpression=Key('key').eq(key_search)
    )

    for it in response['Items']:
        str_out = it['key'] + '\t'
        str_out += it['name'] + '\t'
        str_out += str (it['population']) + '\t'
        str_out += it['date_mod']
        print(str_out)
#
# --------------------------------------------------------------------
def lambda_handler(event, context):
    name_table = 'city'
    key_search='t0922'
    get_proc(name_table,key_search)
#
    return {
        'statusCode': 200,
        'body': json.dumps('Hello from Lambda!')
    }
# --------------------------------------------------------------------

キーを指定してデータの削除

dynamo_delete.py

#! /usr/bin/python
# -*- coding: utf-8 -*-
#
#   dynamo_delete.py
#
#                   Sep/21/2021
# --------------------------------------------------------------------
import sys
import json
import boto3
from boto3.dynamodb.conditions import Key

# --------------------------------------------------------------------
def delete_proc(name_table,key_delete):
    dynamodb = boto3.resource('dynamodb')

    table = dynamodb.Table(name_table)

    response = table.delete_item(
        Key={
        'key': key_delete,
        }
)
# --------------------------------------------------------------------
def lambda_handler(event, context):
    name_table = 'city'
    key_delete = 't0923'
    delete_proc(name_table,key_delete)
#
    return {
        'statusCode': 200,
        'body': json.dumps('Hello from Lambda!')
    }

# --------------------------------------------------------------------

テーブルの削除

dynamo_delete_table.py

#! /usr/bin/python
# -*- coding: utf-8 -*-
#
#   dynamo_delete_table.py
#
#                       Sep/20/2021
# --------------------------------------------------------------------
import  sys
import  json
import  boto3

# --------------------------------------------------------------------
def delete_table_proc(name_table):
    dynamodb = boto3.resource('dynamodb')

    table = dynamodb.Table(name_table)

    table.delete()
#
# --------------------------------------------------------------------
def lambda_handler(event, context):
    name_table = 'city'
    delete_table_proc(name_table)
#
    return {
        'statusCode': 200,
        'body': json.dumps('Hello from Lambda!')
    }
# --------------------------------------------------------------------