Updates to Python DynamoDB provisioning settings.

Author: rlhagerm

python/example_code/dynamodb/GettingStarted/scenario_getting_started_movies.py

@@ -118,10 +118,7 @@ def create_table(self, table_name):
                     {"AttributeName": "year", "AttributeType": "N"},
                     {"AttributeName": "title", "AttributeType": "S"},
                 ],
-                ProvisionedThroughput={
-                    "ReadCapacityUnits": 10,
-                    "WriteCapacityUnits": 10,
-                },
+                BillingMode='PAY_PER_REQUEST',
             )
             self.table.wait_until_exists()
         except ClientError as err:

python/example_code/dynamodb/TryDax/01-create-table.py

@@ -33,7 +33,7 @@ def create_dax_table(dyn_resource=None):
             {"AttributeName": "partition_key", "AttributeType": "N"},
             {"AttributeName": "sort_key", "AttributeType": "N"},
         ],
-        "ProvisionedThroughput": {"ReadCapacityUnits": 10, "WriteCapacityUnits": 10},
+        "BillingMode": "PAY_PER_REQUEST",
     }
     table = dyn_resource.create_table(**params)
     print(f"Creating {table_name}...")

python/example_code/dynamodb/batching/dynamo_batching.py

@@ -50,7 +50,7 @@ def create_table(table_name, schema):
                 {"AttributeName": item["name"], "AttributeType": item["type"]}
                 for item in schema
             ],
-            ProvisionedThroughput={"ReadCapacityUnits": 10, "WriteCapacityUnits": 10},
+            BillingMode='PAY_PER_REQUEST',
         )
         table.wait_until_exists()
         logger.info("Created table %s.", table.name)
@@ -194,14 +194,7 @@ def archive_movies(movie_table, movie_data):
             TableName=f"{movie_table.name}-archive",
             KeySchema=movie_table.key_schema,
             AttributeDefinitions=movie_table.attribute_definitions,
-            ProvisionedThroughput={
-                "ReadCapacityUnits": movie_table.provisioned_throughput[
-                    "ReadCapacityUnits"
-                ],
-                "WriteCapacityUnits": movie_table.provisioned_throughput[
-                    "WriteCapacityUnits"
-                ],
-            },
+            BillingMode='PAY_PER_REQUEST',
         )
         logger.info("Table %s created, wait until exists.", archive_table.name)
         archive_table.wait_until_exists()

python/example_code/dynamodb/batching/test/test_dynamo_batching.py

@@ -27,7 +27,7 @@ def test_create_table(
 
     with stub_runner(error_code, stop_on_method) as runner:
         runner.add(
-            dyn_stubber.stub_create_table, table_name, schema, {"read": 10, "write": 10}
+            dyn_stubber.stub_create_table, table_name, schema
         )
         runner.add(dyn_stubber.stub_describe_table, table_name)
 

python/example_code/dynamodb/partiql/scaffold.py

@@ -46,10 +46,7 @@ def create_table(self, table_name):
                     {"AttributeName": "year", "AttributeType": "N"},
                     {"AttributeName": "title", "AttributeType": "S"},
                 ],
-                ProvisionedThroughput={
-                    "ReadCapacityUnits": 10,
-                    "WriteCapacityUnits": 10,
-                },
+                BillingMode='PAY_PER_REQUEST',
             )
             self.table.wait_until_exists()
         except ClientError as err:

python/test_tools/dynamodb_stubber.py

@@ -77,12 +77,9 @@ def _build_out_item(self, in_item):
                 out_item[key] = {value_type: out_val}
         return out_item
 
-    def stub_create_table(self, table_name, schema, throughput, error_code=None):
+    def stub_create_table(self, table_name, schema, error_code=None):
         table_input = {
-            "ProvisionedThroughput": {
-                "ReadCapacityUnits": throughput["read"],
-                "WriteCapacityUnits": throughput["write"],
-            }
+            "BillingMode": "PAY_PER_REQUEST",
         }
         self._add_table_schema(table_input, table_name, schema)