AWS Data Wrangler

28 - Amazon DynamoDB

Writing Data

[1]:
import awswrangler as wr
import pandas as pd
from pathlib import Path

Writing DataFrame

[2]:
df = pd.DataFrame({
    "key": [1, 2],
    "value": ["foo", "boo"]
})
wr.dynamodb.put_df(df=df, table_name="table")

Writing CSV file

[3]:
filepath = Path("items.csv")
df.to_csv(filepath, index=False)
wr.dynamodb.put_csv(path=filepath, table_name="table")
filepath.unlink()

Writing JSON files

[4]:
filepath = Path("items.json")
df.to_json(filepath, orient="records")
wr.dynamodb.put_json(path="items.json", table_name="table")
filepath.unlink()

Writing list of items

[5]:
items = df.to_dict(orient="records")
wr.dynamodb.put_items(items=items, table_name="table")

Deleting items

[6]:
wr.dynamodb.delete_items(items=items, table_name="table")