Function make_client

samples/stream_consumer.py:33–38

(service: str = "dynamodb")

    ts = time.strftime("%H:%M:%S")
    print(f"[{ts}] [{thread:6s}] {msg}", flush=True)
def make_client(service: str = "dynamodb"):
    return boto3.client(
        service,
        region_name=os.environ.get("AWS_DEFAULT_REGION", "us-east-1"),
        endpoint_url=ENDPOINT,
    )
def wait_for_active(client, table_name: str, timeout: float = 60.0) -> None:
    deadline = time.monotonic() + timeout
    while time.monotonic() < deadline: