def METHOD_NAME(account_id: str, region_name: str, records: dict) -> None:
    kinesis = connect_to(aws_access_key_id=account_id, region_name=region_name).kinesis
    for record in records:
        table_arn = record.pop("eventSourceARN", "")
        if stream := get_stream_for_table(account_id, region_name, table_arn):
            table_name = table_name_from_stream_arn(stream["StreamArn"])
            stream_name = get_kinesis_stream_name(table_name)
            kinesis.put_record(
                StreamName=stream_name,
                Data=dumps(record),
                PartitionKey="TODO",
            )