Yasuke/moto
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

CloudFormation - Support DynamoDB Streams

Browse Source
This commit is contained in:
Bert Blommers 2020-06-04 07:45:00 +01:00
parent 5bd3588f74
commit a66b0e5b1a
2 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
moto/dynamodb2/models/__init__.py
View File

@ -342,6 +342,8 @@ class Table(BaseModel):
params["throughput"] = properties["ProvisionedThroughput"]
if "LocalSecondaryIndexes" in properties:
params["indexes"] = properties["LocalSecondaryIndexes"]
if "StreamSpecification" in properties:
params["streams"] = properties["StreamSpecification"]
table = dynamodb_backends[region_name].create_table(
name=properties["TableName"], **params

7
tests/test_cloudformation/test_cloudformation_stack_integration.py
View File

@ -2307,6 +2307,7 @@ def test_stack_dynamodb_resources_integration():
},
}
],
"StreamSpecification": {"StreamViewType": "KEYS_ONLY"},
},
}
},
@ -2319,6 +2320,12 @@ def test_stack_dynamodb_resources_integration():
StackName="dynamodb_stack", TemplateBody=dynamodb_template_json
)
dynamodb_client = boto3.client("dynamodb", region_name="us-east-1")
table_desc = dynamodb_client.describe_table(TableName="myTableName")["Table"]
table_desc["StreamSpecification"].should.equal(
{"StreamEnabled": True, "StreamViewType": "KEYS_ONLY",}
)
dynamodb_conn = boto3.resource("dynamodb", region_name="us-east-1")
table = dynamodb_conn.Table("myTableName")
table.name.should.equal("myTableName")