Library that helps you create and migrate DynamoDB databases
Project description
dynamodb-migrator
A library that helps you create and migrate DynamoDB databases.
As performant DynamoDB is, that does come with the trade-off of being inflexible. Changing column names or adding secondary indexes is impossible.
The recommended approach is to create a new table with the desired properties, and migrate the existing data.
This library will help you do just that.
Usage
- Write a migration script
- Execute the migration script as a step in the build pipeline
- Add to the migration-script as required
Example
from migrator.dynamodb_migrator import Migrator
migrator = Migrator()
@migrator.version(1)
@migrator.create(AttributeDefinitions=[{
'AttributeName': 'hash_key',
'AttributeType': 'N'
}],
TableName='my_new_table',
KeySchema=[{
'AttributeName': 'hash_key',
'KeyType': 'HASH'
}],
BillingMode='PAY_PER_REQUEST')
def v1(created_table):
print("Table created using the kwargs provided")
print("Note that the keyword-args are passed onto boto as is")
print(created_table)
@NotYetImplemented
@migrator.version(2)
@migrator.add_index("secondary_index_we_forgot_about")
def v2(migrate):
print("About to:")
print(" - Create new table (first_table_v2) with the appropriate index")
print(" - Create DynamoDB Stream on 'first_table' that copies changes into the new table")
print(" - Execute a script that automatically updates all existing data")
print(" (This will trigger all data in 'first_table' to be copied into the new table")
migrate()
print("Table with new index is ready to use")
@NotYetImplemented
@migrator.version(3)
@migrator.delete_table("first_table")
def v3(migrate):
print("About to delete table")
print("Ensure that all upstream applications point to the new table, before adding this part to the pipeline!")
migrate()
print("Table deleted")
@NotYetImplemented
@migrator.version(4)
@migrator.convert(lambda item -> {'id': translate(item.id)})
def v4(migrate):
print("About to:")
print(" - Create new table (first_table_v4)")
print(" - Create a AWS Lambda script that will execute the above lambda, and write the result int he new table")
print(" - Create DynamoDB Stream on 'first_table' that triggers the new Lambda")
print(" - Execute a script that automatically updates all existing data")
print(" (This will trigger all data in 'first_table' to be converted and copied into the new table")
migrate()
print("Table with new data is ready to use")
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for dynamodb_migrator-0.0.2-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 6f1cabc3cddfbd0f2d2673be659bfd7211974469922c685f900f1e910d6bd44a |
|
MD5 | 85c62c70ade484a5abae743aaf1009d1 |
|
BLAKE2b-256 | 009be62cdf1d831bddea60dd0d379f5d10b94467ee596ed66353b02b5cc8dd55 |