code: def create_dynamodb_table(table_name):
      client = DynamoDBHook(client_type="dynamodb").conn
      client.create_table(
          TableName=table_name,
          KeySchema=[
              {
                  "AttributeName": DYNAMODB_TABLE_HASH_KEY,
                  "KeyType": "HASH",
              },
          ],
          AttributeDefinitions=[
              {
                  "AttributeName": DYNAMODB_TABLE_HASH_KEY,
                  "AttributeType": "N",
              },
          ],
          ProvisionedThroughput={
              "ReadCapacityUnits": 20,
              "WriteCapacityUnits": 20,
          },
      )
  
      # DynamoDB table creation is nearly, but not quite, instantaneous.
      # Wait for the table to be active to avoid race conditions writing to it.
      waiter = client.get_waiter("table_exists")
      waiter.wait(TableName=table_name, WaiterConfig={"Delay": 1})
  
file_path: airflow/tests/system/providers/amazon/aws/example_hive_to_dynamodb.py
imports: from __future__ import annotations
  from datetime import datetime
  from airflow.decorators import task
  from airflow.models import Connection
  from airflow.models.baseoperator import chain
  from airflow.models.dag import DAG
  from airflow.providers.amazon.aws.hooks.dynamodb import DynamoDBHook
  from airflow.providers.amazon.aws.transfers.hive_to_dynamodb import HiveToDynamoDBOperator
  from airflow.utils import db
  from airflow.utils.trigger_rule import TriggerRule
  from tests.system.providers.amazon.aws.utils import SystemTestContextBuilder
  from tests.system.utils import get_test_run
label_desc: Use image node_id 1 for calling a global function with example usage: create_dynamodb_table(table_name) without return types