async with await atsq.connect("ts.example.com", 10022,
                              password="...", server_id=1) as ts:
    for row in await ts.client_list("uid", "mytsid"):    # -mytsid: TS6 only
        print(row["clid"], row["client_nickname"])
    cid = await ts.channel_create("Lounge", channel_flag_permanent=1)
    bans = await ts.ban_find(ip="203.0.113.7")            # TS6 only, [] if none

Pull-style event consumption instead of handlers:

async for event in client.events():
    handle(event)
# or: event = await client.wait_for_event(timeout=240)

Anything without a typed wrapper goes through the escape-safe exec(), including pipelined bulk commands (many parameter blocks, one round trip):

rows = await ts.exec("servergrouplist")
await ts.exec("clientmove", clid=5, cid=42)
await ts.exec("channeladdperm", cid=60, blocks=[
    {"permsid": "i_channel_needed_join_power", "permvalue": 75},
    {"permsid": "i_channel_needed_subscribe_power", "permvalue": 60},
])

Wire constants are StrEnums that compare directly against event/row values:

from atsq import ReasonId, TargetMode, ClientType, LEAVE_REASONS

if event["reasonid"] == ReasonId.CONNECT and event["client_type"] == ClientType.VOICE:
    ...
if event.get("reasonid") in LEAVE_REASONS:
    ...

Same API against TS3 and TS6:

ft = atsq.FileTransfer(client)
icon_id = await ft.upload_icon(png_bytes)            # crc32-named, returns the id
data = await ft.download("/file.bin", cid=42)
rows = await ft.file_list(cid=42, path="/")          # [] for empty dirs
await ft.delete_file("/file.bin", cid=42)

try:
    await ts.use(99)
except atsq.QueryError as e:        # error id != 0; str(e) carries the server msg
    print(e.error_id, e.msg)
except atsq.QueryTimeoutError:      # no response in time (connection is closed)
    ...
except atsq.ConnectionClosedError:  # connection gone
    ...

atsq.FloodError (id 524) is retried automatically (flood_retries, default 2).

• Keepalive: automatic whoami after 240 s idle (servers kick at ~300 s). Configure via keepalive_interval; 0 disables.
• Flood protection: an error 524 is retried automatically after the wait the server asks for (flood_retries, default 2; 0 disables). Allowlisted IPs (query_ip_allowlist.txt) never hit it in the first place.
• Reconnect (run_forever): exponential backoff 5 s → 300 s; a server message containing "banned" waits 300 s. use/servernotifyregister and on_ready re-run after every reconnect.
• Host keys: verification is off by default (TeamSpeak servers generate ephemeral query host keys). Pin one in production: atsq.connect(..., known_hosts=...) (forwarded to asyncssh).
• close() sends quit: on TS6 a query client that silently drops the SSH connection never produces a notifyclientleftview; a clean quit does (on both generations).
• Guest sessions (TS6 beta13+): atsq.connect(host, username="guest") needs no password; await ts.login("serveradmin", pw) elevates in-band (and re-selects the virtual server, which login/logout reset).
• Event sources: ALL_EVENTS includes the TS6-only bans source (banupdate events with op=add|del); it is skipped on TS3. server_notify_unregister("textserver") is selective on both generations (TS3 drops everything, so atsq re-registers the rest).
• Snapshots work via plain exec("serversnapshotcreate") / exec("serversnapshotdeploy", version=..., data=...) — deploy deselects the session; call use again afterwards.

Enable SSH query on a TS3 server with TS3SERVER_QUERY_PROTOCOLS=raw,ssh; on TS6 it is the only line protocol (TSSERVER_QUERY_SSH_ENABLED=1, password via TSSERVER_QUERY_ADMIN_PASSWORD).