tiktok-live-events 1.0.0

TikTok LIVE event stream for Python. Read chat, gifts, viewers, follows, PK battles, AI captions, moderation deletes and 50+ real-time event types from any TikTok LIVE stream over a single WebSocket. 2026 edition.

tiktok-live-events

The 2026 TikTok LIVE event stream for Python.

Read chat, gifts, viewers, follows, PK battles, native captions, moderation deletes and 50+ real-time event types from any TikTok LIVE stream in 4 lines of code.

---

What you get

• Real-time chat, gifts, likes, follows, viewer counts, PK battles, AI captions, gift catalog updates, moderation deletes, viewer entry-source analytics and 50+ other live event types.
• One WebSocket. Zero protocol code. No protobuf libraries. No proxy setup. No headless browser.
• Full TypedDict typing for every event - Pyright + mypy autocomplete every field.
• Async first (asyncio). Auto-reconnect. Sync + async handlers both supported.
• Tiny. One runtime dependency (websockets).

The protocol decode happens on the TikTools edge. Your code only ever sees clean JSON.

---

Install

pip install tiktok-live-events

# uv / poetry / pipx
uv add tiktok-live-events
poetry add tiktok-live-events
pipx install tiktok-live-events

---

Quick start

import asyncio
from tiktok_live_events import TikTokLive

live = TikTokLive("streamer_username")

@live.on("connected")
def on_connected(_):
    print("Connected.")

@live.on("chat")
def on_chat(e):
    print(f"{e['user']['uniqueId']}: {e['comment']}")

@live.on("gift")
def on_gift(e):
    print(f"{e['user']['uniqueId']} sent {e['giftName']} x{e['repeatCount']} ({e['diamondCount']} diamonds)")

@live.on("like")
def on_like(e):
    print(f"{e['likeCount']} likes (total: {e['totalLikes']})")

asyncio.run(live.run())

No key. No config. Just run it.

---

Events

Every event is dispatched by name. Handlers receive a dict matching the event's TypedDict (ChatEvent, GiftEvent, BattleArmiesEvent, ...). Each payload extends BaseEvent (type, timestamp, msgId, optional protoVersion).

Core live events

Event	What it carries
connected	Socket open.
disconnected	Socket close.
roomInfo	One-shot post-connect: {roomId, wsHost, clusterRegion, connectedAt}.
chat	user, comment, emotes, optional starred. v3 adds language (auto-detected) + messageUuid.
gift	giftId, giftName, diamondCount, repeatCount, repeatEnd, giftType. v3 adds transactionId, senderUserId, relationship (joinDayNumber).
like	likeCount (this batch), totalLikes (room cumulative).
member	Viewer joined. v3 adds entrySource ("homepage_hot-live_cell", "follow-tab", ...), entryAction ("draw"/"click"), entryType ("rec").
social	Follow / share.
roomUserSeq	Periodic viewer count tick.
subscribe	A viewer subscribed.

PK / battle events

Event	What it carries
battle	PK lifecycle. status (1=ACTIVE, 2=STARTING, 3=ENDED, 4=PREPARING), battleDuration, teams. v3 adds extraHostUserIds, layoutSubtype.
battleArmies	Per-host MVP breakdown. hosts[].contributors[] sorted MVP first. v3 adds transactionId.
battleItemCard	Booster card: x2 / x3 multipliers, gloves (crit), mist, thunder, extra-time, match-guide. Carries TikTok CDN overlay assets.
battlePunishFinish	Loser-side punishment screen ended.
battleNotice, battleGameplay	PK notice + mini-game state.
linkLayer, linkMicOpponentGift, linkScreenChange, cohostLayoutUpdate	Link-mic negotiation, opponent-side gifts, layout flips.
competition, competitionContributor, guestShowdown	Cross-stream competitions + guest showdowns.

Native captions (v3)

Event	What it carries
caption	NEW in v3. TikTok native auto-captions on the LIVE WebSocket. text, isFinal, startedAtMs, endsAtMs.

Creator + room

Event	What it carries
goalUpdate	Stream goal progress (subscriber, gift, watch-time goals).
commentTray, roomPin, roomSticker, inRoomBanner, bottomMessage	Room UI events.
hostBoard, rankText, rankUpdate, hourlyRank	Leaderboard / rank events.
privilegeAdvance, accessRecall, roomVerify	Viewer privilege + content-classification events.
anchorToolModification, streamStatus, shareRevenueNotice	Creator-side metadata flips.
capsule, hotRoom, linkMicAnchorGuide	TikTok host nudges.

Moderation / safety

Event	What it carries
imDelete	Chat moderation delete. Correlate via chat.messageUuid (v3).
unauthorizedMember	Non-logged-in viewer hit a gated feature.
barrage	Raw barrage feed.
superFan, superFanJoin, superFanBox	Super-fan lifecycle.
emoteChat	Inline emote message.

Gift catalog + ecommerce

Event	What it carries
giftPanelUpdate	Real-time gift catalog change.
giftDynamicRestriction, giftGallery, giftUnlock, viewerPicksUpdate	Gift availability flips, host gift wall, gated-gift reveals, viewer-pick highlights.
oecLiveShopping, oecLiveManager, oecLiveBillboard, ecShortItemRefresh	OEC live-shopping events.

Engagement + AI

Event	What it carries
aiSummary	TikTok AI summary of the room (entry-time recap, multi-language).
poll, shortTouch	In-stream poll lifecycle.
question, questionSelected, questionSlideDown	Q&A round events.
pictionaryUpdate, pictionaryEnd, pictionaryExit	Drawing-game rounds.
fansEvent, fanTicket	Fan-club events.
envelope, envelopePortal	Red-envelope drops + multi-room portal chain.
gameMoment, gameServerFeature	TikTok Gaming live integration.
groupLiveMemberNotify	Group-live member join / leave.
perception	Perception event (mute cancel, hint signal).
control, room, liveIntro	Stream control + room metadata.

Catch-all

• event - Fires once for every decoded event (dump-to-queue pattern).
• unknown - Fires when TikTok ships a method not yet modelled (forward-compat hook).

---

Recipes

Chat logger

import asyncio
from tiktok_live_events import TikTokLive

live = TikTokLive("creator")

@live.on("chat")
def on_chat(e):
    print(f"{e['user']['uniqueId']}: {e['comment']}")

asyncio.run(live.run())

Gift leaderboard

import asyncio
from collections import defaultdict
from tiktok_live_events import TikTokLive

live = TikTokLive("creator")
board = defaultdict(int)

@live.on("gift")
def on_gift(e):
    if not e.get("repeatEnd"):
        return
    board[e["user"]["uniqueId"]] += e["diamondCount"] * e["repeatCount"]

async def print_top():
    while True:
        await asyncio.sleep(5)
        top = sorted(board.items(), key=lambda x: -x[1])[:10]
        print("\n-- TOP GIFTERS --")
        for i, (user, diamonds) in enumerate(top, 1):
            print(f"{i:>2}. {user:<20} {diamonds} diamonds")

async def main():
    asyncio.create_task(print_top())
    await live.run()

asyncio.run(main())

PK MVP tracker

import asyncio
from tiktok_live_events import TikTokLive

live = TikTokLive("creator")

@live.on("battle")
def on_battle(e):
    print(f"[battle] status={e['status']} id={e['battleId']} duration={e['battleDuration']}s")

@live.on("battleArmies")
def on_armies(e):
    print(f"[armies] remaining={e.get('secsRemaining')}s")
    for host in e.get("hosts", []):
        print(f"  Host {host['hostUserId']} total={host['teamTotalScore']}")
        mvp = host.get("contributors", [None])[0]
        if mvp:
            print(f"    MVP {mvp['nickname']} {mvp['score']} diamonds")

@live.on("battleItemCard")
def on_card(e):
    if e.get("multiplier", 0) > 0:
        print(f"[card] x{e['multiplier']} booster from {e['senderNickname']}")
    else:
        print(f"[card] effect={e['effect']} from {e['senderNickname']} duration={e['durationSec']}s")

asyncio.run(live.run())

TikTok native captions to file

import asyncio
from tiktok_live_events import TikTokLive

live = TikTokLive("creator")

@live.on("caption")
def on_caption(e):
    if e.get("isFinal"):
        with open("transcript.txt", "a", encoding="utf-8") as f:
            f.write(e["text"] + "\n")

asyncio.run(live.run())

Discord webhook relay

import asyncio, json
import urllib.request
from tiktok_live_events import TikTokLive

WEBHOOK = "https://discord.com/api/webhooks/..."
live = TikTokLive("creator")

def send(content):
    body = json.dumps({"content": content}).encode("utf-8")
    req = urllib.request.Request(WEBHOOK, data=body, headers={"content-type": "application/json"})
    try: urllib.request.urlopen(req, timeout=4).read()
    except Exception: pass

@live.on("chat")
def on_chat(e):
    send(f"**{e['user']['uniqueId']}**: {e['comment']}")

@live.on("gift")
def on_gift(e):
    if e.get("repeatEnd"):
        send(f":gift: {e['user']['uniqueId']} sent {e['giftName']} x{e['repeatCount']} ({e['diamondCount']} diamonds)")

asyncio.run(live.run())

More ready-to-run recipes in examples/.

---

API reference

TikTokLive(unique_id, *, auto_reconnect=True, max_reconnect_attempts=5, debug=False)

Construct a client. unique_id is the TikTok @username (with or without @).

Param	Type	Default	Description
unique_id	str	-	TikTok username.
auto_reconnect	bool	True	Reconnect with exponential backoff if the socket drops.
max_reconnect_attempts	int	5	Stop after N reconnect attempts.
debug	bool	False	Verbose logging via the tiktok_live_events logger.

live.on(event)

Decorator. Register a sync or async handler.

@live.on("chat")
def handler(e): ...

@live.on("gift")
async def handler(e): ...

Pass "event" to receive every decoded event in a single handler.

await live.run()

Connect and pump events until stop() is called or the reconnect budget is exhausted.

live.stop()

Signal run() to exit on the next iteration.

live.connected

bool - whether the socket is currently open.

---

Compatibility

• Python >= 3.9 (uses asyncio, websockets, type hints).
• Works on Windows, macOS, Linux, Docker, serverless.
• Tested against asyncio + uvloop.

---

Powered by

This package connects to the TikTools edge. Schema, decoding, proxy rotation, signing, and protocol patches are handled server-side - your pip install never needs to bump when TikTok ships a wire change.

---

License

MIT

This is an independent third-party project. Not affiliated with, endorsed by, or in any way officially connected to TikTok or ByteDance Ltd. "TikTok" is a trademark of ByteDance Ltd; the name appears here for search discoverability.