Function log

samples/stream_consumer.py:30–32

(thread: str, msg: str)

# Shared state
stop_poller = threading.Event()
def log(thread: str, msg: str) -> None:
    ts = time.strftime("%H:%M:%S")
    print(f"[{ts}] [{thread:6s}] {msg}", flush=True)
def make_client(service: str = "dynamodb"):
    return boto3.client(
        service,